[
https://issues.apache.org/jira/browse/CAMEL-20790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Otavio Rodolfo Piske resolved CAMEL-20790.
------------------------------------------
Resolution: Fixed
Resolved with the linked PR.
> kafka batching consumer polls randomly failing with NPE under load
> ------------------------------------------------------------------
>
> Key: CAMEL-20790
> URL: https://issues.apache.org/jira/browse/CAMEL-20790
> Project: Camel
> Issue Type: Bug
> Components: camel-kafka
> Affects Versions: 4.4.2, 4.6.0
> Reporter: Ihar Reznichenka
> Assignee: Otavio Rodolfo Piske
> Priority: Minor
> Labels: help-wanted
> Fix For: 4.7.0
>
> Attachments: KafkaBatchingProcessingManualCommitExchangeListNPEIT.java
>
>
> A camel-kafka batching consumer is randomly catching NPEs.
> This is happening with and w/o manual commit.
> If the consumer is configured with pollOnError=RETRY then it causes lost
> records.
> Please find a test to reproduce the issue attached.
>
>
> {code:java}
> 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)
> at
> org.apache.camel.component.kafka.KafkaFetchRecords.run(KafkaFetchRecords.java:173)
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
> at
> java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
> at java.base/java.lang.Thread.run(Thread.java:840) {code}
>
> Please let me know if any additional details are required here.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
