У нас есть приложение, которое запускает активный / пассивный режим, и у нас есть 2 кластера kafka, которые работают в активном / активном режиме. Происходит следующее: время от времени один из кластеров kafka должен быть отключен на время обслуживания, поэтому в этом случае, если наше приложение активно в datacenter1 и в том же кластере kafka в центре обработки данных отключено, мы должны вручную переключиться. Перейдите в кластер дата-центра 2 kafka в конфигурации приложения, чтобы продолжить обработку сообщений (как производителя, так и потребителя). Есть ли лучший способ определить, не работает ли кластер kafka, чтобы динамически / программно переключаться на другой кластер весной kafka lib?