This is the same logs i get with my local kafka server, that works fine.. On 5 April 2016 at 10:20, Ratha v <vijayara...@gmail.com> wrote:
> 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/ > -- -Ratha http://vvratha.blogspot.com/
