假设我有两个主题,即主题1和主题2。topic1使用topicnamestrategy,topic2使用topicrecordnamestrategy。如何配置这两个主题?
iyzzxitl1#
由于这是在转换器中配置的,并且转换器是在辅助进程或连接器级别配置的,因此需要创建两个连接器,每个连接器都根据该连接器读取的主题设置主题名策略。另见Kafka连接不与主题策略工作
1条答案
按热度按时间iyzzxitl1#
由于这是在转换器中配置的,并且转换器是在辅助进程或连接器级别配置的,因此需要创建两个连接器,每个连接器都根据该连接器读取的主题设置主题名策略。
另见Kafka连接不与主题策略工作