1

Как при помощи утилиты зеркального копирования kafka-mirror-maker.sh скопировать данные из топика source-кластера Kafka в топик target-кластера с другим именем?

К примеру: в первом кластере Kafka есть топик с именем test_topic_names, я хочу забрать данные из этого топика и скопировать содержимое в другой кластер Kafka в топик с другим именем test_topic.

Благодарю за внимание.

2
  • Версии исходного кластера и целевого одинаковые? Commented 7 нояб. 2018 в 15:45
  • Версия целевого кластера 2.0.0, версия исходного 1.0.0 Commented 8 нояб. 2018 в 7:11

1 ответ 1

1

Вам необходимо написать свой MessageHandler, имплементирующий интерфейс MirrorMakerMessageHandler, и передать класс в аргументах к MirrorMaker (--message.handler). В MessageHandler будут подаваться на вход все сообщения из исходного в кластера, с которыми вы вольны делать все, что угодно. Подробнее можно прочитать тут: https://github.com/gwenshap/kafka-examples/blob/master/MirrorMakerHandler/README.md , https://www.opencore.com/blog/2017/1/170131-mirrormaker-change-topic/ , пример имплементации можно увидеть тут: https://github.com/opencore/mirrormaker_topic_rename .

1

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.