MirrorMaker 2.0: должны ли темы существовать в целевом кластере перед запуском MirrorMaker?

В моем исходном кластере есть набор тем, по которым публикуются данные. У меня есть эти названия тем, указанные в файле свойств 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)

Означает ли это, что в целевом кластере необходимо заранее создать темы и разделы?


person bdev03    schedule 11.06.2020    source источник


Ответы (2)


Я просматривал тему с тем же именем, что и в исходной теме, но имя темы в целевом кластере - .topic1.

person bdev03    schedule 12.06.2020

Нет, MM 2.0 берет на себя ответственность за создание реплицированной темы в целевом кластере. Название темы в целевом кластере будет sourceAlias ​​..

Дополнительные сведения см. Здесь: https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0#KIP382:MirrorMaker2.0-Config,ACLSync

person PAVAN PURANIK    schedule 01.08.2020