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