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