我只找到了mirrormaker v2的参考资料。
我可以重复使用吗 org.apache.kafka.connect.mirror.MirrorSourceConnector
好像它是一个以Kafka为源的“普通”连接器,或者有其他更简单的东西可用吗?
我尝试使用kafkaconnect和它的smt(组合)来模拟在其他消息代理中发现的消息路由行为。
例如,我想使用一个主题,从消息中提取值(头或负载),并根据消息中找到的数据将消息路由到同一集群中的另一个主题。
谢谢您
我只找到了mirrormaker v2的参考资料。
我可以重复使用吗 org.apache.kafka.connect.mirror.MirrorSourceConnector
好像它是一个以Kafka为源的“普通”连接器,或者有其他更简单的东西可用吗?
我尝试使用kafkaconnect和它的smt(组合)来模拟在其他消息代理中发现的消息路由行为。
例如,我想使用一个主题,从消息中提取值(头或负载),并根据消息中找到的数据将消息路由到同一集群中的另一个主题。
谢谢您
1条答案
按热度按时间0s0u357o1#
在同一集群内
这就是Kafka流或ksqldb的用途。您可以通过代码直接导入和使用smt方法,尽管您还需要使用connect converter类来获取大多数smt所需的模式/结构类型
虽然可以使用mirrormaker,但集群间的重新定位并不是它的目的