Камрады, помогите плиз лыжи развернуть в нужную сторону - не едут.
Есть докер-кластер, созданный в docker-compose, в котором 6 докер-контейнеров:
- Одна нода Zookeeper
- Три ноды Kafka-brokers
- Одна нода test-producer
- Одна нода test-consumer
Test-producer каждую секунду пуляет в Кафку текущую дату-время а test-consumer этот месседж читает.
Все работает, как часы :)
Но когда я, в целях осознания надёжности, начинаю шатать кластер и гашу по очереди брокеров, возникает непонятный мне результат.
Два брокера укладываются нормально и test-consumer продолжает получать из кластера месседжи.
Но всегда есть третий (случайный по номеру) брокер, на котором test-producer затыкается и начинает выбрасывать ошибку:
Couldn't resolve server kafka-2:29092 from bootstrap.servers as DNS resolution failed for kafka-2 (org.apache.kafka.clients.ClientUtils)
При этом Zookeeper все отрабатывает, elections проводятся, контроллер кластера и лидеры партиций переназначаются (т.е. вопрос не к Кафке)
Интернету я уже начитался до пузырей и чёт пока в тупике по этому вопросу.
Можете плиз показать, куда грести?