Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> kafka.common.FailedToSendMessageException - 0.8


Copy link to this message
-
Re: kafka.common.FailedToSendMessageException - 0.8
Before that log entry, you should see why the send fails in WARN. Could you
post that? Also, any error/exception in the broker log (including
state-change log)?

Thanks,

Jun
On Thu, Jun 20, 2013 at 12:08 AM, Ran RanUser <[EMAIL PROTECTED]> wrote:

> I'm stumped:
>
> My sample Producer code does not work in Windows, but does work in Linux
> (Ubunuty).
>
> My sample Consumer code is fine.
>
> - Kaka 0.8 (June 19), compiled using Scala 2.9.2
> - Java version is JDK 1.7x (Oracle version in Windows, OpenJDK on Ubuntu)
> - 1 broker, 1 partition,1 replica, no compression, topic already created
> called "test"
> - Producer code throws exception when producer runs on Windows 7 regardless
> if Kaka broker is running in Windows 7 or Ubuntu 12.04
> - Producer code works if run on Ubuntu 12.04
> - Consumer code works on Windows
>
> Producer code:
>
>     val topic = "test"
>     val props = new Properties()
>     props.put("serializer.class", "kafka.serializer.StringEncoder");
>     props.put("metadata.broker.list", "192.168.1.200:9092");
>     val producer = new Producer[String, String](new ProducerConfig(props))
>     val msg = new KeyedMessage(topic, "key1", "value1")
>     try {
>       producer.send(msg)
>     }
>     catch {
>       case e: Exception =>
>         ...
>     }
>
> Stack trace:
>
> 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 shops.runner.Runner$.main(Runner.scala:91)
>
>
> Any ideas?
>
>
> Thank you!
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB