如何在kafka connect elasticsearch中Map使用不同主题名策略的多个主题

unguejic  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(299)

假设我有两个主题,即主题1和主题2。topic1使用topicnamestrategy,topic2使用topicrecordnamestrategy。如何配置这两个主题?

iyzzxitl

iyzzxitl1#

由于这是在转换器中配置的,并且转换器是在辅助进程或连接器级别配置的,因此需要创建两个连接器,每个连接器都根据该连接器读取的主题设置主题名策略。
另见Kafka连接不与主题策略工作

相关问题