如何在 kafka 融合连接器中指定要侦听的主题

Question

我最近一直在研究 kafka 连接器，我想知道在哪里配置接收器连接器的工作线程任务应该侦听的主题。

通常，SinkConnectorConfig 如下所示

name=MySinkConnector
tasks.max=1
connector.class=com.operative.creative.bi.sink.MySinkConnector
topics=demo
filePath=/tmp/output.txt

当使用 REST-proxy 控制工作线程配置时，可以覆盖这些设置。我想知道我们在哪里指定主题。

我知道属性文件定义了一个名为 "topics" 的属性，但我在样板代码中没有看到任何读取它的内容。

任何帮助将不胜感激。

Answer 1

topic = props.get(TOPIC_CONFIG);

看看 https://docs.confluent.io/current/connect/devguide.html#connector-example，也看看 https://gist.github.com/jcustenborder/b9b1518cc794e1c1895c3da7abbe9c08