Hi, I have 2 brokers with a topic with replication factor = 2. Brokers are configured with min.insync.replicas=2.
I use a producer in asynchronous mode to send 100000 messages. After some seconds after producer start, I stop one broker. On producer side I got no exceptions, so for producer application is all OK, but in broker log message I see ERROR [Replica Manager on Broker 0]: Error processing append operation on partition diameternew-10 (kafka.server.ReplicaManager) So I lost all messages after broker shutdown. Is there a way to catch as soon as possible this kind of exeption ? I know that I can use m_kafkaProducer.send(prMessage).get(); or Future _future = m_kafkaProducer.send(prMessage); or callback in send method, but they are very slow. Thank.