如何在kafka confluent connector中指定要侦听的主题？

kq4fsx7k 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(319)

我最近一直在研究kafka连接器&我想知道在哪里配置sink连接器的worker任务应该监听的主题。
通常，sinkconnectorconfig如下所示

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

当使用rest代理控制worker配置时，可以覆盖这些设置。我想知道我们在哪里指定主题。
我知道属性文件定义了一个名为 "topics" 但我在锅炉板代码里没看到任何东西。
任何帮助都将不胜感激。

1条答案

topic = props.get(TOPIC_CONFIG);

看一看https://docs.confluent.io/current/connect/devguide.html#connector-例如https://gist.github.com/jcustenborder/b9b1518cc794e1c1895c3da7abbe9c08