spring-kafka - Acknowledgement.acknowledge() 空点异常
问题描述
我已经关闭了自动提交,设置MANUAL_IMMEDIATE
,但它也会产生空点异常
这是一个例外:
(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String, java.lang.String>>,org.springframework.kafka.support.Acknowledgment)' threw exception; nested exception is java.lang.NullPointerException; nested exception is java.lang.NullPointerException
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:1311) [spring-kafka-2.2.5.RELEASE.jar!/:2.2.5.RELEASE]
解决方案
2.2.x 不再受支持,2.2.5 已经 2 1/2 年了。
有关支持的版本,请参阅项目页面。
那是 2.2.5 中的一个错误——这意味着某些代码无缘无故地抛出了一个错误ListenerExecutionFailedException
;我没有在框架代码中看到这种情况(但我没有仔细查看),也许你的代码正在抛出它?
报告此类问题时,您必须显示代码、配置、日志和完整的堆栈跟踪。
尝试升级到受支持的版本 - 2.3.14、2.5.15、2.6.10 或 2.7.6 - 越新越好。
推荐阅读
- xslt - XSLT:获取相对 URI 而不是绝对 uri
- sas - 每次调用宏时如何告诉 SAS 编译宏而不是手动编译
- typescript - 重复的 TreeView 架构是 VS 代码扩展
- c# - 如何找到标记为“玩家”的游戏对象
- c# - 如何使用 C# 创建对谷歌日历 API 的 HTTP GET 请求?
- javascript - eslint 不允许以模式结尾的文件名
- linux - 打印以特殊字符开头的整个日志
- java - 我不能从我的代理类转发异常
- javascript - 如何在 Nodejs 中分离和重用 mongodb 连接
- c# - 单元测试 - 控制器没有从 ASP.NET Core Web API 项目中的模拟 IConfiguration 中获取价值