You are working on a Kafka cluster with three nodes.

With acks=all and min.insync.replicas=2, Kafka requiresat least two in-sync replicasto acknowledge a write. If onlyone broker is alive, the condition fails, andNotEnoughReplicasExceptionis thrown by the producer.

FromKafka Producer Exception Docs:

“NotEnoughReplicasException is thrown when the number of in-sync replicas is insufficient to satisfy acks=all with min.insync.replicas.”

NetworkException is generic and not raised here.

NotCoordinatorException is related to consumer group coordination.

NotLeaderForPartitionException is unrelated unless accessing an unassigned leader.