Hi, Testing out some kafka consistency guarantees I have following basic producer config:
ProducerConfig.ACKS_CONFIG=all ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG=true ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION=1 ProducerConfig.RETRIES_CONFIG=3 My test setup is a 3 node kafka cluster (3 zk nodes) running on windows, with min.insync.replicas set to 1. A test topic is configured with replication factor 3 and 10 partitions. The behavior that i'm seeing is that even though I take down 2 brokers, the producer does not fail when sending messages. As far as I understood, taking down 2 out of 3 brokers means there are no replicas (assuming the leader is not a replica of itself) hence the producer should not be able to produce a message. Interestingly, when i configure the brokers with min.insync.replicas=2 the message producer fails when I shutdown 2 brokers. Thanks, Jorg
