Всем привет! Может кто-то знает, можно ли сделать межкластерную репликацию

для topic1? topic1 должен содержать одинаковые данные, если сообщение попало в topic1(A), то должно попасть и в topic1(B), но и в обратную сторону это тоже должно работать. Пробовал MirrorMaker конфигурацию Active/Active, но если принудительно убирать префиксы, то данные дублируются.

А какую проблему решаешь? Расскажи чуть подробнее

Нужно сделать переключение между стендами. Приложение работает с кластером кафки на основном стенде, в случае переключения приложение выключается на основном стенде, а на запасном стенде поднимается его копия и должна продолжить работу с этими же данными. Через какое-то время нужно переключить всё обратно, и чтобы результат работы за время переключения не потерялся нужно скопировать новые данные обратно на основной кластер.

Вам нужно миррормейкер синхронно с переключением включать в нужную сторону и гасить в обратную.

Ну или делать не один, а три топика. И не два, а 6 мирормейкеров. И реплицировать A1-B2, A2-B1, A1-C1, B1-C1, A2-C2,B2-C2.

У меня было такое, что при Active/Passive при сбое MM данные в топиках дублировались(x9) и самое страшное что сразу в двух кластерах. Настройка ММ без префиксов*

Confluent Cluster Linking. Остальные - это поделия и велосипеды

Проблема в том что купить нельзя раз, а во вторых еще и внутри запрещено

Привет! Можно попросить описать проблему чуть подробнее (может в личку)? Очень похоже, что описываемая проблема - требование "надежности" одного из наших серо-буро-малиновых банков. Сам бьюсь над этим. Возможно, стоит объединить опыт\усилия.