(camel) branch kd updated: CAMEL-23023: camel-kafka - Kafka consumers are started eager before CamelContext is fully started

[davsclaus]

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

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


The following commit(s) were added to refs/heads/kd by this push:
     new b851c6c6d6e1 CAMEL-23023: camel-kafka - Kafka consumers are started 
eager before CamelContext is fully started
b851c6c6d6e1 is described below

commit b851c6c6d6e1740b674b0038348db2c4b3c43e0f
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed Mar 11 20:48:07 2026 +0100

    CAMEL-23023: camel-kafka - Kafka consumers are started eager before 
CamelContext is fully started
---
 .../main/java/org/apache/camel/component/kafka/KafkaComponent.java | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
index 704273acf9ca..9a8413d368f4 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
@@ -296,4 +296,11 @@ public class KafkaComponent extends HealthCheckComponent 
implements SSLContextPa
         PropertyBindingSupport.bindProperties(getCamelContext(), map, 
configuration.getAdditionalProperties());
         configuration.setAdditionalProperties(map);
     }
+
+    @Override
+    protected void doShutdown() throws Exception {
+        super.doShutdown();
+        pendingConsumers.clear();
+    }
+
 }