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/11/13 14:36:11 UTC
[camel] branch CAMEL-17131 created (now 1bdd191)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-17131
in repository https://gitbox.apache.org/repos/asf/camel.git.
at 1bdd191 CAMEL-17131: camel-kafka - Consumer should not be in reconnect state on startup as this causes to create the kafka consumer twice on startup, which is also causing a JMX duplicate MBean error, and let alone the creation of the consumer again.
This branch includes the following new commits:
new 1bdd191 CAMEL-17131: camel-kafka - Consumer should not be in reconnect state on startup as this causes to create the kafka consumer twice on startup, which is also causing a JMX duplicate MBean error, and let alone the creation of the consumer again.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel] 01/01: CAMEL-17131: camel-kafka - Consumer should not be in reconnect state on startup as this causes to create the kafka consumer twice on startup, which is also causing a JMX duplicate MBean error, and let alone the creation of the consumer again.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch CAMEL-17131
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1bdd1913939254fdfdba6feb11a41342ec6a709b
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Nov 13 15:35:29 2021 +0100
CAMEL-17131: camel-kafka - Consumer should not be in reconnect state on startup as this causes to create the kafka consumer twice on startup, which is also causing a JMX duplicate MBean error, and let alone the creation of the consumer again.
---
.../main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 0f600a9..c0119f4 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
@@ -62,7 +62,7 @@ class KafkaFetchRecords implements Runnable {
private final ConcurrentLinkedQueue<KafkaAsyncManualCommit> asyncCommits = new ConcurrentLinkedQueue<>();
private boolean retry = true;
- private boolean reconnect = true;
+ private boolean reconnect; // must be false at init
KafkaFetchRecords(KafkaConsumer kafkaConsumer, PollExceptionStrategy pollExceptionStrategy,
BridgeExceptionHandlerToErrorHandler bridge, String topicName, Pattern topicPattern, String id,