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 you have read our privacy policy.

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