Hi, We are getting following exception in storm kafka spout. Workers are not able to process any messages as it keeps restarting. We are running on storm 0.9.6 version. Topology is running from last 1 year without any issues. But, since last 2 days we started getting this exception. We tried re-starting topology by deleting old offsets from zookeeper but issue occurs again in few hours.
java.lang.IndexOutOfBoundsException at java.nio.Buffer.checkIndex(Buffer.java:546) at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:365) at kafka.message.Message.sliceDelimited(Message.scala:229) at kafka.message.Message.payload(Message.scala:218) at storm.kafka.KafkaUtils.generateTuples(KafkaUtils.java:199) at storm.kafka.PartitionManager.next(PartitionManager.java:131) at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:141) at backtype.storm.daemon.executor$fn__3371$fn__3386$fn__3415.invoke(executor.clj:572) at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463) at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:745) DP
