消费kafka BufferUnderflowException 错误处理

在消费kafka的时候,遇到一个错误, java.nio.BufferUnderflowException

2017-10-12 15:49:32,450 WARN [main] org.apache.hadoop.mapred.YarnChild: Exception running child : java.nio.BufferUnderflowException

单纯查这个错误,得到的是buffer 读取的问题,反复减小 startOffset之后,依旧没有改变,通过网上查得到有可能是 运行的kafka版本 和 使用的kafka的包版本不同导致的,于是替换 pom中 org.apache.kafka版本,于是问题解决

Leave a comment

Your email address will not be published.

*