[camel-spring-boot] branch main updated: ✅ Fix KafkaConsumerHealthCheck Test

[acosentino]

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

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git


The following commit(s) were added to refs/heads/main by this push:
     new 9c0b4c37650 ✅ Fix KafkaConsumerHealthCheck Test
9c0b4c37650 is described below

commit 9c0b4c37650dfdf68968bd82fac5bfc470fc38d0
Author: Croway <federico.mariani.1...@gmail.com>
AuthorDate: Mon Jul 18 13:58:05 2022 +0200

    ✅ Fix KafkaConsumerHealthCheck Test
---
 .../camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
 
b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
index 31a383c5307..3ef6ff6f19d 100644
--- 
a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
+++ 
b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
@@ -180,7 +180,7 @@ public class KafkaConsumerHealthCheckIT extends 
BaseEmbeddedKafkaTestSupport {
                     = res2.stream().filter(r -> 
r.getState().equals(HealthCheck.State.DOWN)).findFirst();
             Assertions.assertTrue(down.isPresent());
             String msg = down.get().getMessage().get();
-            Assertions.assertEquals("KafkaConsumer is not ready (recovery in 
progress using 5s intervals).", msg);
+            Assertions.assertTrue(msg.contains("KafkaConsumer is not ready"));
             Map<String, Object> map = down.get().getDetails();
             Assertions.assertEquals(TOPIC, map.get("topic"));
             Assertions.assertEquals("test-health-it", map.get("route.id"));