为什么消费者从kafka中获取到的ConsumerRecord数据不完整?
在调试java代码时发现调用consumer.poll()方法从kafka中获取到的ConsumerRecord数据不完整。
以上是我调试java代码时,观察的一条ConsumerRecord数据,可以看到它的value值为空,但是其他值是正常的。于是我按照partition和offset找到并查看了kafka中这条消息的内容(见下图),发现它的数据却是完整的(存在value值)
调试时程序处在获取数据阶段,并没有对数据进行任何处理,也就是说程序获取到的数据就是缺少value值的。自己排查了半天也没有头绪,不清楚为何会这样,期待大佬解答我的困惑,万分感激!
回答:
1.看下poll()的源码
2.从kafka配置上看下有没有配置缺失
3.升级一下kafka版本
以上是 为什么消费者从kafka中获取到的ConsumerRecord数据不完整? 的全部内容, 来源链接: utcz.com/p/944151.html