В последнее время я работал над коннектором kafka, и я хотел знать, где настроить темы, которые должна прослушивать моя рабочая задача коннектора приемника.
Обычно SinkConnectorConfig выглядит так
name=MySinkConnector
tasks.max=1
connector.class=com.operative.creative.bi.sink.MySinkConnector
topics=demo
filePath=/tmp/output.txt
и эти настройки могут быть переопределены при использовании rest-proxy для управления конфигурациями рабочих. Я хочу знать, где мы указываем тему.
Я знаю, что файл свойств определяет свойство с именем "topics", но я не видел ничего, что читало бы его в коде базовой пластины.
Любая помощь будет оценена по достоинству.
