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