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
> >
>
