Quickstart
Использование Kafka v2.1.0 на RHEL v6.9

Потребитель не получает данные, когда один из брокеров Kafka не работает.

Шаги выполнены:
1. Запустите зоопарка
2. Запустите Kafka-Server0 (локальный хост: 9092, kafkalogs1)
3. Запустите Kafka-Server1 (локальный хост: 9094, kafkalog2)
4. Создайте тему «test1», количество разделов = 1, коэффициент репликации = 2
5. Запустите продюсера для темы "test1"
6. Запустите потребителя
7. Отправляйте сообщения от производителя
8. Получать сообщения на стороне потребителя.

Все вышеперечисленные шаги работали без проблем.

Когда я выключаю Kafka-Server0, потребитель перестает получать данные от производителя. Когда я возвращаюсь к Kafka-Server0, потребитель начинает получать сообщения с того места, где он остановился.

Эти команды используются

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test1

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

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9094 --topic test1

Любая идея, почему потребитель перестает получать сообщения, когда server0 не работает, даже если коэффициент репликации для темы test1 был установлен на 2?

Уже есть подобный вопрос, но он не был полностью отвеченБыстрый старт Kafka 0.10: потребитель терпит неудачу, когда «основной» брокер не работает