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



这只是我提出的一个愚蠢的问题,但我真的很想让这里的任何人创建一个以主题为目的地的kafka连接器接收器。

流程将变成这样,主题a->连接器->主题b。或者有什么建议可以让它像那样运行吗?

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

相关内容

最新更新