Port spring-cloud Kafka HealthIndicator to spring-boot about spring-boot HOT 3 CLOSED

Unfortunately, I think you'll have to implement your own, tailored to how your application's using Kafka.

from spring-boot.

Thanks for the suggestion.

Unfortunately, I don't see how the health indicator from Spring Cloud Stream's Kafka binder can be ported to Spring Boot. The Kafka binder has a lot more information available to it about how Kafka's being used than a general Spring Boot app does. This information allows it to identify what it should check to determine whether or not Kafka's healthy for its purposes. Spring Boot doesn't have this information available and has to fall back on a more general-purpose approach.

It sounds like you have already seen #14088 which describes why it isn't possible to offer a general-purpose health indicator for Kafka. I don't think anything's changed since then and it makes sense for Spring Cloud Stream's Kafka Binder to continue to provide its own indicator.

from spring-boot.

Thanks for the fast reply!

Yes, I already investigated #14088 sadly I thought it may not be possible even with the given example in the spring-cloud project. I thought it helped but I "tried" to reimplement that behavior and found out as you mentioned that the information I have is much less compared to the spring-cloud way 😄

I saw that the spring-cloud implementation got a KafkaTopicProvisioner which provides a ton of information for the check. So I understand the fact that it isn't easy to provide an out-of-the-box working check for everyone.

My hopes were high that somehow having a port without the need to implement it on my own with the risk of problems when I need to upgrade to newer versions 😄

from spring-boot.