在kafka connector中,如何获取kafka connect当前使用的引导服务器地址?

db2dz4w8  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(411)

我正在自己开发一个KafkaFlume连接器。我的反序列化程序是jsonverter。但是,当有人将错误的json数据发送到我的连接器的主题中时,我希望省略此记录并将此记录发送到我公司的特定主题。
我的困惑是:我找不到任何api来获取connect的bootstrap.servers(我知道它在confluent的etc目录中,但编写“connect distributed.properties”目录的硬代码来获取bootstrap.servers不是一个好主意)
那么问题是,有没有其他方法可以让我在连接器程序中方便地获得bootstrap.servers的值呢?

6rvt4ljy

6rvt4ljy1#

与其尝试将“坏”记录从sinktask发送到kafka,不如尝试使用kafka connect 2.0中添加的死信队列功能。
您可以将connect运行时配置为自动将无法处理的记录转储到作为dlq的已配置主题。
有关更多详细信息,请参见添加此功能的kip。

相关问题