spring-cloud / spring-cloud-stream-binder-kafka

Spring Cloud Stream binders for Apache Kafka and Kafka Streams
Apache License 2.0
331 stars 302 forks source link

Spring Cloud Stream binder #1180

Closed abdulshaikh76 closed 2 years ago

abdulshaikh76 commented 2 years ago

how does actuator work for health check of spring cloud binder ?

when kafka server is down , of my consume application the actuator health check showing me that it is down . I would like to write my own custom health check for Eureka server to update the same status . so i would like to understand the implementation of actuator/health check .

sobychacko commented 2 years ago

@abdulshaikh76 Currently, the health indicator in the Kafka binder is not conditional. If you want to write your own custom health indicator, then we need to change the current configuration so that it is only included conditionally. Then you can write your own implementation.

sobychacko commented 2 years ago

@abdulshaikh76 See the referenced PR above. Take a look at the documentation in the commit to see the details on how you can exclude the default implementation and add your own.