有没有可能让一个kafka镜像生成器从一个源kafka集群读取一个主题源的数据,然后将这些数据写入一个名为target的主题中的目标kafka集群?我在镜像生成器中查找一些producer配置属性,以指定目标主题名称。提前谢谢
jhiyze9q1#
要使用mirrormaker实现这一点,您需要创建一个定制的messagehandler,在其中可以执行必要的转换。我在这里创建了一个例子https://github.com/opencore/mirrormaker_topic_rename 这也许能帮到你。如果您还有其他问题,请告诉我。
1条答案
按热度按时间jhiyze9q1#
要使用mirrormaker实现这一点,您需要创建一个定制的messagehandler,在其中可以执行必要的转换。
我在这里创建了一个例子https://github.com/opencore/mirrormaker_topic_rename 这也许能帮到你。
如果您还有其他问题,请告诉我。