kafka connect可以使用主题作为源然后将其下沉到另一个主题吗？

Question

这只是我提出的一个愚蠢的问题，但我真的很好奇这里有没有人创建一个以主题为目的地的 kafka 连接器接收器。

流程会变成这样，topic a -> connector -> topic b。或者有什么建议可以让它这样运行吗？

Answer 1

这就是 Confluent 中的 MirrorMaker 2 和 Replicator 的工作方式。它们是为主题的集群间复制而设计的，但我想你没有理由不能将它们用于集群内。