Re: Failed to Send Message After 3 Tries

So, this is expected behavior on the producer when its unable to communicate with the kafka broker that is the leader for the message is being sent. First, if the design of your app allows, try to migrate to the new producer API release is 0.8.1 It is fully asynchronous, and provides callbacks

Failed to Send Message After 3 Tries

Hi there, We had error logs for three messages failed to produce to Kafka during last week. All three are failed on the same day within one hour range. We checked Kafka logs (server.log and statechange.log) but found no abnormal behaviors. The exception is : kafka.common.FailedToSendMes

Re: Just started with Kafka. This test is throwing failed to send message after 3 tries, could help please? what is wrong with my test.

Could you re-format your code in the email? They can hard be read from my browser. Guozhang On Thu, Apr 10, 2014 at 6:58 AM, Khalef Bessaih wrote: > I am using the latest version of kafka. > package kafka.test; > import kafka.consumer.Consumer;import kafka.consumer.ConsumerConfig;import > kafka

Just started with Kafka. This test is throwing failed to send message after 3 tries, could help please? what is wrong with my test.

I am using the latest version of kafka. package kafka.test; import kafka.consumer.Consumer;import kafka.consumer.ConsumerConfig;import kafka.consumer.ConsumerIterator;import kafka.consumer.KafkaStream;import kafka.javaapi.consumer.ConsumerConnector;import kafka.javaapi.producer.Producer;import k