Reactor Kafka Binder 健康指示器
Reactor Kafka binder 提供了一个 HealthIndicator 实现,该实现将在调用 Spring Boot Actuator health 端点时使用。当 Spring Boot actuator 依赖项位于类路径上时,Reactor Kafka binder 可以通过一个 binder 健康指示器启用。此健康指示器提供有关基于 binder 的应用程序状态的信息,即它当前是 UP 还是 DOWN,应用程序正在使用的主题,以及 binder 内部使用的消息生产者组件的各种详细信息。
Reactor Kafka Binder 健康指示器在框架内部以 reactorKafka 为键进行注册。因此,可以按如下所示以编程方式查询它。
CompositeHealthContributor compositeHealthContributor = context
.getBean("bindersHealthContributor", CompositeHealthContributor.class);
ReactorKafkaBinderHealthIndicator healthIndicator = (ReactorKafkaBinderHealthIndicator) compositeHealthContributor.getContributor("reactorKafka");
Health health = healthIndicator.health();