Как отправить sh сообщение второму кластеру kafka topi c, если первый кластер вышел из строя с помощью java

Question

У меня есть сценарий, в котором мне нужно отправить сообщение sh в kafka topi c, используя java .... но условие: если мой один кластер выходит из строя, необходимо подключить другой кластер kafka и pu sh сообщение.

Answer 1

Вам потребуется настроить два DefaultKafkaProducerFactory bean-компонента и два KafkaTemplate s.

При получении исключения переключитесь на другой шаблон.