Strimzi MirrorMaker2 перезапуск / сброс темы

Мы используем Strimzi MirrorMaker2 CRD для репликации данных из одного кластера Kafka в другой. Репликация теперь синхронизирована, и я заметил, что смещение темы для одной темы (с 3 разделами) неверно, у источника больше сообщений, чем у цели.

Я бы хотел перезапустить эту единственную тему в MM2, не затрагивая ни одну из синхронизируемых тем. Я не видел в документации, как перезапустить только одну тему, возможно ли?

У нас есть около 12 синхронизируемых тем, и в идеале перезапуск не повлияет на них.

Спасибо!


person RyanS    schedule 26.03.2021    source источник


Ответы (1)


Я не думаю, что Mirror Maker 2 позволяет перезапускать только для одной темы. Он работает как несколько разных коннекторов Kafka Connect, которые выполняют разные задачи. Но у них нет экземпляров по теме. Вы можете использовать это для перезапуска коннектора или это, чтобы перезапустить задачу. Но вы не можете выбрать конкретную тему, поскольку каждая задача будет обрабатывать несколько из них.

person Jakub    schedule 26.03.2021