We had this issue as well but never the less the message was enqueued four times into the cluster. It would be great to get any hint on this issue.
regards -- Markus Roder Am 25.06.2013 um 07:18 schrieb Yogesh Sangvikar <yogesh.sangvi...@gmail.com>: > Hi Jun, > > The stack trace we found is as follow, > > log4j:WARN No appenders could be found for logger > (kafka.utils.VerifiableProperties). > log4j:WARN Please initialize the log4j system properly. > 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:74) > at kafka.javaapi.producer.Producer.send(Producer.scala:32) > at > com.pearson.firehose.KafkaProducer.publishTinCanMessage(KafkaProducer.java:27) > at com.pearson.firehose.KafkaProducer.main(KafkaProducer.java:44) > > Please let me know if you need the complete producer code. > > Thanks, > Yogesh Sangvikar > > > On Tue, Jun 25, 2013 at 10:05 AM, Jun Rao <jun...@gmail.com> wrote: > >> Could you attach the log before FailedToSendMessageException in the >> producer? It should tell you the reason why the message can't be sent. >> >> Thanks, >> >> Jun >> >> >> On Mon, Jun 24, 2013 at 9:20 PM, Yogesh Sangvikar < >> yogesh.sangvi...@gmail.com> wrote: >> >>> Hi Team, >>> >>> We are using kafka-0.8.0-beta1-candidate1 release. ( >>> https://github.com/apache/kafka/tree/0.8.0-beta1-candidate1). >>> While running producer with following configuration, we found an issue >>> "kafka.common. >>> FailedToSendMessageException: Failed to send messages after 3 tries", >>> >>> We are using default broker configurations. >>> >>> Code snippet: >>> >>> private Producer<byte[], byte[]> producer = null; >>> >>> public KafkaProducer() { >>> Properties props = new Properties(); >>> props.put("metadata.broker.list", "broker1:9092< >>> http://10.252.8.168:9092> >>> ,broker2:9092 <http://10.252.8.48:9092>,broker3:9092< >>> http://10.252.8.234:9092> >>> ,broker4:9092 <http://10.252.8.121:9092>,broker5:9092< >>> http://10.252.8.236:9092> >>> "); >>> *props.put("producer.type", "sync");* >>> ProducerConfig config = new ProducerConfig(props); >>> producer = new Producer<byte[], byte[]>(config); >>> } >>> >>> public void publishTinCanMessage(String message, int event) throws >>> Exception { >>> KeyedMessage<byte[], byte[]> data = new KeyedMessage<byte[], >>> byte[]>("tin_can_topic", >>> (String.valueOf(event%3)).getBytes(),message.getBytes()); >>> producer.send(data); >>> >>> } >>> ...... >>> >>> Found issue: >>> 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:74) >>> at kafka.javaapi.producer.Producer.send(Producer.scala:32) >>> at >> com.pearson.firehose.KafkaProducer.publishTinCanMessage(KafkaProducer.java:27) >>> at com.pearson.firehose.KafkaProducer.main(KafkaProducer.java:44) >>> >>> >>> >>> But. with *props.put("producer.type", "async"); *the producer was working >>> fine and generating messages. >>> >>> Could you please help us to understand is there any configuration missing >>> or is there any issue with "producer.type=sync"? >>> >>> >>> Thanks in advance. >>> >>> Thanks, >>> Yogesh Sangikar >>
