Kafka Quickstart
Usando o Kafka v2.1.0 no RHEL v6.9

O consumidor falha ao receber dados quando um dos corretores Kafka está inoperant

Etapas realizadas:
1. Iniciar zookeeper
2. Inicie o Kafka-Server0 (localhost: 9092, kafkalogs1)
3. Inicie o Kafka-Server1 (host local: 9094, kafkalog2)
4. Crie o tópico "test1", número de partições = 1, fator de replicação = 2
5. Executar produtor para o tópico "test1"
6. Executar consumidor
7. Envie mensagens do produtor
8. Receba mensagens no lado do consumidor.

odas as etapas acima funcionaram sem problema

Quando eu desligo o Kafka-Server0, o consumidor para de obter dados do Producer. Quando ligo o Kafka-Server0, o consumidor começa a receber mensagens de onde parou.

Estes são os comandos usados

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

O comportamento é o mesmo (nenhuma mensagem recebida no lado do consumidor) quando eu executo o consumidor com dois servidores especificados na opção --bootstrap-serve

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

Alguma idéia de por que o consumidor para de receber mensagens quando server0 está inativo, mesmo que o fator de replicação do tópico test1 tenha sido definido como

Já existe uma pergunta semelhante, mas não foi respondida completamente Kafka 0.10 quickstart: consumidor falha quando o intermediário "primário" é desativado