You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/08/03 14:05:31 UTC
[camel] branch main updated: CAMEL-16832: camel-kafka - file
descriptor leak (#5915)
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 <10...@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 <je...@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);
}