You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Camel Kafka批量处理间歇性轮询失败(伴NullPointerException)致消息丢失问题咨询

Camel Kafka批量处理间歇性轮询失败(伴NullPointerException)致消息丢失问题咨询

各位大佬好,我这边在使用Camel Kafka组件做批量消息读取和处理时,碰到了一个间歇性的轮询失败问题,还导致了消息丢失,实在头疼,想请教下有没有遇到过类似情况的朋友或者大佬能给点思路?

我们的业务逻辑是基于Camel Kafka实现批量拉取消息并处理,但时不时会出现轮询失败的情况,抛出的NullPointerException具体栈信息如下:

java.lang.NullPointerException: Cannot invoke "java.util.List.add(Object)" because "this.exchangeList" is null
    at org.apache.camel.component.kafka.consumer.support.batching.KafkaRecordBatchingProcessor.processExchange(KafkaRecordBatchingProcessor.java:137)
    at org.apache.camel.component.kafka.consumer.support.batching.KafkaRecordBatchingProcessorFacade.processPolledRecords(KafkaRecordBatchingProcessorFacade.java:59)
    at org.apache.camel.component.kafka.KafkaFetchRecords.startPolling(KafkaFetchRecords.java:353)

目前我们在Camel 4.4.0和4.6.0版本上都遇到了这个问题,两个版本的表现完全一致,有没有朋友知道这可能是什么原因导致的?或者有没有什么排查方向可以推荐?

备注:内容来源于stack exchange,提问作者Sparta

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.16 11:09:39