跳到主要内容

Reactor Kafka 绑定器健康指标

DeepSeek V3 中英对照 Reactor Kafka Binder Health Indicator

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();
java