This is an automated email from the ASF dual-hosted git repository.
apupier 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 a4445cd6bd06 Fix KafkaConsumerHealthCheckIT
a4445cd6bd06 is described below
commit a4445cd6bd06a608e2679e4a470f6a3899e13cc8
Author: Aurélien Pupier <[email protected]>
AuthorDate: Tue Aug 25 09:26:53 2026 +0200
Fix KafkaConsumerHealthCheckIT
regression introduced by usage of singleton service
https://github.com/apache/camel/commit/bb6882f9f2f041015227f874fb4b51910d09ee9c
the test is doing a shutdown of the service, it doesn't sound safe to do
it on a singletonservice used by other tests and anyways it seems thtait
wasn't implemented correctly for this singletonservice so revert back to
a "normal" service
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../component/kafka/integration/health/KafkaHealthCheckTestSupport.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaHealthCheckTestSupport.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaHealthCheckTestSupport.java
index 33c51f76c90e..cfcfa874baa0 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaHealthCheckTestSupport.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaHealthCheckTestSupport.java
@@ -48,7 +48,7 @@ abstract class KafkaHealthCheckTestSupport implements
ConfigurableRoute, Configu
protected static final Logger LOG =
LoggerFactory.getLogger(KafkaConsumerUnresolvableHealthCheckIT.class);
@Order(1)
@RegisterExtension
- protected static KafkaService service =
KafkaServiceFactory.createSingletonService();
+ protected static KafkaService service =
KafkaServiceFactory.createService();
@Order(2)
@RegisterExtension
