我的源集群有一组要向其发布数据的主题。我在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)
这是否意味着主题和分区需要在目标集群中预先创建?
2条答案
按热度按时间ql3eal8s1#
不,mm2.0负责在目标集群中创建一个复制的主题。目标群集中的主题名称将是sourcealias。。
有关更多详细信息,请参阅:https://cwiki.apache.org/confluence/display/kafka/kip-382%3a+mirrormaker+2.0#kip382:mirrormaker2.0-config,aclsync
bqf10yzr2#
我正在查看与源主题同名的主题,但目标集群中的主题名为.topic1。