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
相关产品推荐
相关产品推荐

