我正在为流处理设置storm,我的三叉戟喷口正在从kafka主题获取数据,但在从kafka获取消息时,我不断收到bufferunderflowexception:
java.lang.runtimeexception:java.lang.runtimeexception:java.nio.bufferunderflowexception位于backtype.storm.utils.disruptorqueue.consumebatchtocursor(disruptorqueue)。java:128)~[风暴核心-0.9.5。jar:0.9.5]在backtype.storm.utils.disruptorqueue.consumebatchwhenavailable(disruptorqueue。java:99)~[风暴核心-0.9.5。jar:0.9.5]原因:java.lang.runtimeexception:java.nio.bufferunderflowexception at storm.kafka.kafkautils.fetchmessages(kafkautils。java:177)~[stormjar]。jar:na]在Storm中。Kafka。三叉戟。三叉戟。获取消息(三叉戟。java:132)~[stormjar]。jar:na]在Storm中。Kafka。三叉戟。三叉戟。Kafka密特。多米特新分区批处理(三叉戟Kafka密特。java:113) ~[stormjar]。jar:na]
原因:java.nio.bufferunderflowexception:java.nio.heapbytebuffer.get(heapbytebuffer)处为null。java:151)~[na:1.8.0\u 05]位于java.nio.bytebuffer.get(bytebuffer。java:715)~[na:1.8.0\u 05]kafka.api.apiutils$.readshortstring(apiutils。scala:40)~[stormjar]。jar:na]
我使用的storm版本是0.9.5,kafka版本是2.11。我不明白是什么造成了这里的问题。
1条答案
按热度按时间okxuctiv1#
如果您将不同版本的kafka客户机用于您的代理,则可能会出现类似的错误。