Reactor Kafka Binder 健康指标

Reactor Kafka binder 提供了一个HealthIndicator实现,该实现将在调用 Spring Boot Actuator 的health端点时使用。当 Spring Boot Actuator 依赖项位于类路径上时,可以使用 Binder 健康指标启用 Reactor Kafka 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();