Весенняя кафка потребительская на 2 кафки кластера

Question

У меня есть два кластера: кластер-1 на сайте 1 (3 брокера) и кластер-2 на сайте 2 (3 брокера).Использование Spring Kafka (1.3.6) для потребителя (одна машина) и прослушивание сообщений через аннотацию @KafkaListener.Как создать несколько экземпляров KafkaListenerContainerFactory для каждого кластера (c1 и c2) и прослушивать данные из обоих кластеров одновременно.

Мой слушатель должен получать сообщения от обоих кластеров одновременно.

Answer 1

Kafka автоматически подключится к обоим экземплярам, ​​вам больше ничего не нужно делать.

Просто добавьте оба адреса в конфигурацию bootstrap.servers, чтобы клиент мог подключиться, даже если один из посредников не работает (но разделы должны быть достаточно реплицированы).