[camel] 02/02: CAMEL-17947: remove unnecessary consumer close

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 7cfd7d314315d0c9340d99d6ea61cefb1c79a1fa
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Aug 2 11:31:25 2022 +0200

    CAMEL-17947: remove unnecessary consumer close
    
    Closing the consumer is already handled by the KafkaConsumer if necessary 
or by evaluating the poll exception strategy
---
 .../main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java   | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
index af29ba74840..2dcaf162b4f 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
@@ -161,8 +161,6 @@ public class KafkaFetchRecords implements Runnable {
         if (LOG.isInfoEnabled()) {
             LOG.info("Terminating KafkaConsumer thread {} receiving from {}", 
threadId, getPrintableTopic());
         }
-
-        IOHelper.close(consumer);
     }
 
     private void setupInitializeErrorException(ForegroundTask task, int max) {