为什么消费者从kafka中获取到的ConsumerRecord数据不完整?

新手上路,请多包涵

在调试java代码时发现调用consumer.poll()方法从kafka中获取到的ConsumerRecord数据不完整。

EF[~YS)U(X93E{C}S$}_800.png

以上是我调试java代码时,观察的一条ConsumerRecord数据,可以看到它的value值为空,但是其他值是正常的。于是我按照partition和offset找到并查看了kafka中这条消息的内容(见下图),发现它的数据却是完整的(存在value值)

20220104171024.png

调试时程序处在获取数据阶段,并没有对数据进行任何处理,也就是说程序获取到的数据就是缺少value值的。自己排查了半天也没有头绪,不清楚为何会这样,期待大佬解答我的困惑,万分感激!

阅读 4.3k
1 个回答

1.看下poll()的源码
2.从kafka配置上看下有没有配置缺失
3.升级一下kafka版本

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题