0

我的源集群有一组要发布数据的主题。我在 mirrormaker 属性文件中指定了这些主题名称。我还没有在目标集群中创建主题。我的假设是，如果这些主题不存在，MM 2.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)

这是否意味着需要在目标集群中预先创建主题和分区？

4

2 回答 2

0

不，MM 2.0 负责在目标集群中创建复制主题。目标集群中的主题名称将是 sourceAlias..

有关更多详细信息，请参阅：https ://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0#KIP382:MirrorMaker2.0-Config,ACLSync

于 2020-08-01T08:42:18.337 回答
0

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

于 2020-06-12T00:43:50.717 回答