[camel] branch main updated: CAMEL-16832: camel-kafka - file descriptor leak (#5915)

[davsclaus]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 657e5c5  CAMEL-16832: camel-kafka - file descriptor leak (#5915)
657e5c5 is described below

commit 657e5c5121e9138122f22d80f96c23342a20711b
Author: jenskordowski <10864787+jenskordow...@users.noreply.github.com>
AuthorDate: Tue Aug 3 16:05:07 2021 +0200

    CAMEL-16832: camel-kafka - file descriptor leak (#5915)
    
    * CAMEL-16832: camel-kafka - file descriptor leak
    
    * Update KafkaConsumer.java
    
    Co-authored-by: Jens Kordowski <jens.kordow...@sap.com>
---
 .../src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index a5cfd16..05a734b 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -534,8 +534,8 @@ public class KafkaConsumer extends DefaultConsumer {
                     }
                 }
             } finally {
-                // only close if not retry or re-connecting
-                if (!retry.get() && !reconnect.get()) {
+                // only close if not retry
+                if (!retry.get()) {
                     LOG.debug("Closing consumer {}", threadId);
                     IOHelper.close(consumer);
                 }