That was it!
I didn't have logging setup correctly, so I missed those extra clues.
Not using the kafka instance hostname in the producer caused the topic
metadata requests to fail.
Thank you!
On Thu, Jun 20, 2013 at 3:01 PM, Jun Rao wrote:
> Before that log entry, you should see why the send
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 wrote:
> I'm stumped:
>
> My sample Producer code does not work in Windows
I had similar problem with my setup. It may be different for you but in my
case the producer could not resolve the broker host as registered in
zookeeper. You make a request to the address specified in brokers list,
which successfully returns the topic metadata but the broker might have
registered
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 compr
