MirrorMaker2.0:在启动mirrormaker之前,主题是否需要存在于目标集群中?

nhjlsmyf  于 2021-06-05  发布在  Kafka
关注(0)|答案(2)|浏览(457)

我的源集群有一组要向其发布数据的主题。我在mirrormaker属性文件中指定了这些主题名称。我还没有在目标集群中创建主题。我的假设是,如果这些主题不存在,mm2.0会自动在目标集群中创建它们。但是,当我尝试从目标集群中的主题消费时,我看到了以下消息- [2020-06-11 21:45:19,301] WARN [Consumer clientId=consumer-console-consumer-78249-1, groupId=console-consumer-78249] Error while fetching metadata with correlation id 4790 : {topic1=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) 这是否意味着主题和分区需要在目标集群中预先创建?

ql3eal8s

ql3eal8s1#

不,mm2.0负责在目标集群中创建一个复制的主题。目标群集中的主题名称将是sourcealias。。
有关更多详细信息,请参阅:https://cwiki.apache.org/confluence/display/kafka/kip-382%3a+mirrormaker+2.0#kip382:mirrormaker2.0-config,aclsync

bqf10yzr

bqf10yzr2#

我正在查看与源主题同名的主题,但目标集群中的主题名为.topic1。

相关问题