Это все уже делается на выходе из нашей кафки. Здесь нужен простой и надежный коннектор, потому что работает в закрытом контуре. А что можно сказать о надежности ММ и репликатора ?
Ребаланс, например Если у вас довольно много партиций в кластере, то любой ребаланс мм (например, упала одна нода) может минут на 15 и больше остановить репликацию
Метаданные не передаются нормально, поэтому чтобы переключить консьюмеров на другой кластер, надо писать отдельный инструмент (если нужно сохранить положение офсетов)
С уберРепликатором так: поднял два кафка кластера по 3 ноды. Между ними засунул этот репликатор. В сурс кластере запустил генерацию сообщений. И они потекли в дест-кластер. Дальше роняю 1 или 2 ноды на сурсе. Все ок. Поднимаю обратно — тоже.
Вот это в новом ММ должно быть исправлено. По крайней мере так сказано в доках
Мы пока с ним не до конца разобрались Не очень понятно есть ли уже сейчас поддержка консьюмер групп на несколько кластеров (в планах было такое сделать, но как это работает не разобрались с ходу)