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

github-bot pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit f944d8a28b12e849aec5fed1368bfea6a1976540
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Tue Aug 1 07:36:19 2023 +0100

    Fix CamelKafkaHealthCheckTest
---
 .../camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java | 6 +++---
 .../camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java   | 4 +++-
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
 
b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
index 8ac3abb560..31d4111ba4 100644
--- 
a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
+++ 
b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
@@ -52,8 +52,8 @@ public class CamelKafkaHealthCheckTest {
                 .contentType(ContentType.JSON)
                 .header("Content-Type", containsString("charset=UTF-8"))
                 .body("status", is("DOWN"),
-                        "checks.find { it.name == 'camel-components' 
}.status", is("DOWN"),
-                        "checks.find { it.name == 'camel-components' 
}.data.topic", notNullValue(),
-                        "checks.find { it.name == 'camel-components' 
}.data.'client.id'", notNullValue());
+                        "checks.find { it.name == 'camel-producers' }.status", 
is("DOWN"),
+                        "checks.find { it.name == 'camel-producers' 
}.data.topic", notNullValue(),
+                        "checks.find { it.name == 'camel-producers' 
}.data.'client.id'", notNullValue());
     }
 }
diff --git 
a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
 
b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
index 620c5dcd3f..5a80ef842c 100644
--- 
a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
+++ 
b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
@@ -24,6 +24,8 @@ public class KafkaHealthCheckProfile implements 
QuarkusTestProfile {
     @Override
     public Map<String, String> getConfigOverrides() {
         // force shutdown
-        return Map.of("camel.main.shutdownTimeout", "10");
+        return Map.of(
+                "camel.main.shutdownTimeout", "10",
+                "camel.health.producers-enabled", "true");
     }
 }

Reply via email to