[jira] [Created] (CAMEL-18627) camel-kafka: Kafka resume throws null pointer exception if no partition offset exists

["rupam (Jira)" <ji...@apache.org>]

rupam created CAMEL-18627:
-----------------------------

             Summary: camel-kafka: Kafka resume throws null pointer exception if no partition offset exists
                 Key: CAMEL-18627
                 URL: https://issues.apache.org/jira/browse/CAMEL-18627
             Project: Camel
          Issue Type: Task
          Components: camel-kafka
    Affects Versions: 3.17.0
            Reporter: rupam
            Assignee: Otavio Rodolfo Piske
             Fix For: 3.18.3, 3.20.0


 

In the startPolling() method, if the consumer is suspending, then the unsubscribe method is called which permanently closes the consumer

 
{code:java}
    Duration pollDuration = Duration.ofMillis(pollTimeoutMs);
    while (isKafkaConsumerRunnable() && isConnected() && pollExceptionStrategy.canContinue()) {
        ConsumerRecords<Object, Object> allRecords = consumer.poll(pollDuration);
        if (consumerListener != null) {
            if (!consumerListener.afterConsume(consumer)) {
                continue;
            }
        }

        ProcessingResult result = recordProcessorFacade.processPolledRecords(allRecords);

        if (result.isBreakOnErrorHit()) {
            LOG.debug("We hit an error ... setting flags to force reconnect");
            // force re-connect
            setReconnect(true);
            setConnected(false);
        }

        updateTaskState();
    }

    if (!isConnected()) {
        LOG.debug("Not reconnecting, check whether to auto-commit or not ...");
        commitManager.commit();
    }

    safeUnsubscribe();
} catch (InterruptException e) {{code}
 

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)