Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

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


+
Ran RanUser 2013-06-20, 07:09
+
Marc Labbe 2013-06-20, 12:49
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!
>

 
+
Ran RanUser 2013-06-23, 07:14
+
Yogesh Sangvikar 2013-06-25, 04:21
+
Jun Rao 2013-06-25, 04:36
+
Yogesh Sangvikar 2013-06-25, 05:19
+
Jun Rao 2013-06-25, 16:39
+
Markus Roder 2013-06-25, 05:56
+
Florin Trofin 2013-06-25, 07:12
+
Jonathan Hodges 2013-06-25, 10:58
+
Jonathan Hodges 2013-06-25, 11:09
+
Yogesh Sangvikar 2013-06-25, 14:38
+
Florin Trofin 2013-06-25, 17:12
+
Yogesh Sangvikar 2013-06-26, 09:13
+
Jun Rao 2013-06-25, 16:42
+
Kalpa 1977 2014-07-07, 16:19