The send() method returns a Future. You need to get the result at some point to see what happened. A simple way would be:
m_kafkaProducer.send(prMessage).get(); -Dave -----Original Message----- From: Agostino Calamita [mailto:agostino.calam...@gmail.com] Sent: Friday, September 9, 2016 9:33 AM To: users@kafka.apache.org Subject: No error to kafka-producer on broker shutdown Hi, I'm writing a little test to check Kafka high availability, with 2 brokers, 1 topic with replication factor = 2 and min.insync.replicas=2. This is the test: System.out.println("Building KafkaProducer..."); KafkaProducer<byte[],byte[]> m_kafkaProducer = new KafkaProducer<byte[],byte[]>(propsProducer); System.out.println("Building ProducerRecord..."); ProducerRecord<byte[], byte[]> prMessage = new ProducerRecord<byte[],byte[]>(strTopic, jsonInString.getBytes()); long now = System.currentTimeMillis(); .... for (int i=0; i<3; i++) { try { for(int x=1; x<= numMessages; x++) m_kafkaProducer.send(prMessage); System.out.println("Wait for 60 seconds"); Thread.sleep(60000); } catch(Exception e) { System.out.println("Error sending message : " + e.getMessage()); } } . . . When test is running, after first step of "for cicle", I kill one broker, so only one broker remains alive. When the test execute second and third cicle, no errors are caught by kafka-producer; I see only error on kafka broker logs. The test terminate successfully, with messages not really sent. In this way my application that use "async" producer is not able to catch invalid state of kafka brokers. Is there a way to catch this kind of errors on kafka producers ? Thanks. This e-mail and any files transmitted with it are confidential, may contain sensitive information, and are intended solely for the use of the individual or entity to whom they are addressed. If you have received this e-mail in error, please notify the sender by reply e-mail immediately and destroy all copies of the e-mail and any attachments.
