You should see the cause in WARN. It seems that your log4j is not set up properly
Thanks, Jun On Mon, Jun 24, 2013 at 10:18 PM, Yogesh Sangvikar < yogesh.sangvi...@gmail.com> wrote: > 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 > > > > > >
