1

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

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

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

2
  • Версии исходного кластера и целевого одинаковые? 7 ноя 2018 в 15:45
  • Версия целевого кластера 2.0.0, версия исходного 1.0.0 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

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

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