I get the following error from my producer when sending a message: Caused by: kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90) at kafka.producer.Producer.send(Producer.scala:76) at kafka.javaapi.producer.Producer.send(Producer.scala:42) at com.servicemagic.kafka.producer.KafkaProducerTemplate.send(KafkaProducerTemplate.java:37) ... 31 more
The producer is running locally, the broker is on a different machine. I can telnet to the broker, so it isn't a network issue. Also, I have other producers that work fine using the same broker (but a different topic).
I've checked the various logs on the broker, but I don't see anything obvious in them. I'm not sure how to turn up the logging level, though, so perhaps there would be useful info if I could do that.
Can you give me some suggestions on how to troubleshoot this issue?
Could you provide information on why each retry failed. Look for an error message that says "Failed to send producer request". On Wed, Jun 25, 2014 at 2:18 PM, England, Michael <[EMAIL PROTECTED]> wrote:
The output from the list topic tool suggests that a leader is available for all partitions. Is the LeaderNotAvailableException repeatable? Are you running Kafka in the cloud? On Wed, Jun 25, 2014 at 4:03 PM, England, Michael <[EMAIL PROTECTED]> wrote:
I'm not so sure what is causing those exceptions. When you send data, do you see any errors in the server logs? Could you send it around? On Fri, Jun 27, 2014 at 10:00 AM, England, Michael <[EMAIL PROTECTED]