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(6);
} 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.
