kafka.common.FailedToSendMessageException - 0.8

[Ran RanUser]

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!