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"); } }