ストリーム処理用のストームを設定しています。トライデント スパウトは kafka トピックからデータをフェッチしていますが、kafka からメッセージをフェッチしている間、連続して BufferUnderFlowException を取得しています。
java.lang.RuntimeException: java.lang.RuntimeException: java.nio.BufferUnderflowException at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) ~[storm-core-0.9.5.jar:0.9.5] backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99) ~[storm-core-0.9.5.jar:0.9.5] 原因: java.lang.RuntimeException: java.nio.BufferUnderflowException at storm. kafka.KafkaUtils.fetchMessages(KafkaUtils.java:177) ~[stormjar.jar:na] at storm.kafka.trident.TridentKafkaEmitter.fetchMessages(TridentKafkaEmitter.java:132) ~[stormjar.jar:na] at storm.kafka. trident.TridentKafkaEmitter.doEmitNewPartitionBatch(TridentKafkaEmitter.java:113) ~[stormjar.jar:na]
原因: java.nio.BufferUnderflowException: null at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:151) ~[na:1.8.0_05] at java.nio.ByteBuffer.get(ByteBuffer.java:715) ~[ na:1.8.0_05] kafka.api.ApiUtils$.readShortString(ApiUtils.scala:40) で ~[stormjar.jar:na]
私が使用しているストームのバージョンは 0.9.5 で、kafka のバージョンは 2.11 です。ここで何が問題を引き起こしているのか理解できません。