[camel] branch main updated: [CAMEL-17839] camel-kafka: fix health checks and failing KafkaConsumerHealthCheckIT (#7276)

[davsclaus]

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

davsclaus 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 69ab928  [CAMEL-17839] camel-kafka: fix health checks and failing 
KafkaConsumerHealthCheckIT (#7276)
69ab928 is described below

commit 69ab92809e2359268afdf568388bed7e7ebc5206
Author: John Poth <poth.j...@gmail.com>
AuthorDate: Mon Mar 28 14:57:27 2022 +0200

    [CAMEL-17839] camel-kafka: fix health checks and failing 
KafkaConsumerHealthCheckIT (#7276)
---
 .../java/org/apache/camel/component/kafka/KafkaConsumerHealthCheck.java | 1 +
 .../java/org/apache/camel/component/kafka/KafkaProducerHealthCheck.java | 2 ++
 2 files changed, 3 insertions(+)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumerHealthCheck.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumerHealthCheck.java
index e759191..2429156 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumerHealthCheck.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumerHealthCheck.java
@@ -82,5 +82,6 @@ public class KafkaConsumerHealthCheck extends 
AbstractHealthCheck {
                 return; // break on first DOWN
             }
         }
+        builder.up();
     }
 }
diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducerHealthCheck.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducerHealthCheck.java
index 34fde2a..8be0c2a 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducerHealthCheck.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducerHealthCheck.java
@@ -59,6 +59,8 @@ public class KafkaProducerHealthCheck extends 
AbstractHealthCheck {
                 builder.detail("group.id", gid);
             }
             builder.detail("topic", cfg.getTopic());
+        } else {
+            builder.up();
         }
     }
 }