You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Paritosh Anand <ka...@gmail.com> on 2016/09/14 17:30:41 UTC

Kafka spout not working

Hi,

I am not able to submit a topology that reads messages from kafka. Below is
the error trace

Storm version - 1.0.2
Kafka version - 0.10.0.0

17286 [SyncThread:0] ERROR o.a.s.s.o.a.z.s.NIOServerCnxn - Unexpected
Exception:
java.nio.channels.CancelledKeyException
at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
~[?:1.8.0_102]
at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:77)
~[?:1.8.0_102]
at org.apache.storm.shade.org.apache.zookeeper.server.
NIOServerCnxn.sendBuffer(NIOServerCnxn.java:151)
[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.shade.org.apache.zookeeper.server.
NIOServerCnxn.sendResponse(NIOServerCnxn.java:1081)
[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.shade.org.apache.zookeeper.server.FinalRequestProcessor.
processRequest(FinalRequestProcessor.java:404) [storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.shade.org.apache.zookeeper.server.
SyncRequestProcessor.flush(SyncRequestProcessor.java:200)
[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.shade.org.apache.zookeeper.server.
SyncRequestProcessor.run(SyncRequestProcessor.java:131)
[storm-core-1.0.2.jar:1.0.2]

Can anyone point what can be the issue here.