Closed hb12devtn closed 4 months ago
We can resolve this by adding a ReactorKafkaBinderHealthIndicator
bean to ReactorKafkaBinderConfiguration
:
@Bean
public ReactorKafkaBinderHealthIndicator reactorKafkaBinderHealthIndicator(ReactorKafkaBinder binder, ConsumerFactory<?, ?> cf) {
return new ReactorKafkaBinderHealthIndicator(binder, cf);
}
Alternatively, we can create a separate configuration class, similar to KafkaBinderHealthIndicatorConfiguration, specifically for ReactorKafkaBinderHealthIndicator.
Thanks, @hb12devtn; we will look at this soon.
Hi, I encountered an issue while working with Spring Cloud Stream where the ReactorKafkaBinderHealthIndicator class is not being found. Upon further investigation, it appears that the health check for the binders is consistently showing "UNKNOWN" status. This is because the
binderHealthContributors
map within theBindersHealthContributor
class is always empty, leading to theobtainContributor
method returning theUNKNOWN
health contributor. It seems that the binderHealthContributors map is not being populated with any health contributors, hence the health status remains "UNKNOWN" for the binders.Here's the relevant code snippet from the
BindersHealthContributor
class:Steps to Reproduce:
Expected Behavior:
Actual Behavior:
Additional Information: