镜像制作者目标主题名称与源主题名称不同

Question

是否有可能有一个 Kafka 镜像制造商从源 kafka 集群读取来自主题 source 的数据并将这些数据写入名为 target?

我正在寻找镜像制造商中的一些生产者配置属性来指定目标主题名称。

提前致谢

Answer 1

要使用 MirrorMaker 实现此目的，您需要创建一个自定义 MessageHandler，您可以在其中执行必要的转换。

我在https://github.com/opencore/mirrormaker_topic_rename 创建了一个示例，可能会对您有所帮助。

如果您还有其他问题，请告诉我。