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 <ranuse...@gmail.com> 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!
>
