HI Niko; I face this issue with linux systems.. I changed the logging level to debug and when I start and stop my consumer (stopping the program) I get same exception. What is the cause here?
[2016-04-05 00:01:08,784] DEBUG Connection with /192.xx.xx.248 disconnected (org.apache.kafka.common.network.Selector) kafka_1 | java.io.EOFException kafka_1 | at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) kafka_1 | at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) kafka_1 | at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:153) kafka_1 | at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:134) kafka_1 | at org.apache.kafka.common.network.Selector.poll(Selector.java:286) kafka_1 | at kafka.network.Processor.run(SocketServer.scala:413) kafka_1 | at java.lang.Thread.run(Thread.java:745) kafka_1 | [2016-04-05 00:01:09,236] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnxn) kafka_1 | [2016-04-05 00:01:11,236] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnxn) kafka_1 | [2016-04-05 00:01:13,238] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnxn) kafka_1 | [2016-04-05 00:01:14,078] DEBUG Connection with /192.168.0.248 disconnected (org.apache.kafka.common.network.Selector) kafka_1 | java.io.EOFException kafka_1 | at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) kafka_1 | at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) kafka_1 | at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:153) kafka_1 | at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:134) kafka_1 | at org.apache.kafka.common.network.Selector.poll(Selector.java:286) kafka_1 | at kafka.network.Processor.run(SocketServer.scala:413) kafka_1 | at java.lang.Thread.run(Thread.java:745) kafka_1 | [2016-04-05 00:01:15,240] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnxn) kafka_1 | [2016-04-05 00:01:17,240] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnxn) kafka_1 | [2016-04-05 00:01:19,242] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnxn) kafka_1 | [2016-04-05 00:01:19,558] DEBUG Connection with /192.xx.xx.248 disconnected (org.apache.kafka.common.network.Selector) kafka_1 | java.io.EOFException kafka_1 | at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) kafka_1 | at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) kafka_1 | at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:153) kafka_1 | at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:134) kafka_1 | at org.apache.kafka.common.network.Selector.poll(Selector.java:286) kafka_1 | at kafka.network.Processor.run(SocketServer.scala:413) kafka_1 | at java.lang.Thread.run(Thread.java:745) kafka_1 | [2016-04-05 00:01:21,242] DEBUG Got ping response for sessionid: 0x253405b88b300a4 after 0ms (org.apache.zookeeper.ClientCnx On 5 April 2016 at 04:29, Niko Davor <nikoda...@gmail.com> wrote: > 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. > -- -Ratha http://vvratha.blogspot.com/
