M. Lohith Samaga, Your Java code looks fine.
Usually, if consumer.poll(100); doesn't return, there is probably a basic connection error. If Kafka can't connect, it will internally go into an infinite loop. To me, that doesn't seem like a good design, but that's a separate tangent. Turn SLF4J root logging up to debug and you will probably see the connection error messages. A second thought is it might be worth trying using Kafka on a small Linux VM. The docs say, "Windows is not currently a well supported platform though we would be happy to change that.". Even if you want to use Windows as a server in the long run, at least as a development test option, I'd want to be able to test with a Linux VM. FYI, I'm a Kafka newbie, and I've had no problems getting working code samples up and running with Kafka 0.9.0.1 and the new Producer/Consumer APIs. I've gotten code samples running in Java, Scala, and Python, and everything works, including cross language tests. Lastly, as a mailing list question, how do I reply to a question like this if I see the original question in the web archives but it is not in my mail client? I suspect that this reply will show up as a different thread which is not what I want.
