Hello, I seem to come across a issue with replication. We have 2 nodes where Kafka and yarn run.
We have enabled replication factor on Kafka (Replication factor = 2). For testing redundancy, we shutdown broker01 server. On the yarn application logs, we see the exception kafka.common.ReplicaNotAvailableException Incoming topic: /opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --topic raw --describe Topic:raw PartitionCount:1 ReplicationFactor:2 Configs: Topic: argos-raw Partition: 0 Leader: 1018019533 Replicas: 1018019533,1018019532 Isr: 1018019533,1018019532 Out going topic: /opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --topic parser --describe Topic:parser PartitionCount:1 ReplicationFactor:2 Configs: Topic: argos-parser Partition: 0 Leader: 1018019533 Replicas: 1018019533,1018019532 Isr: 1018019533,1018019532 Any idea on why this could be happening? - Shekar
