Reactor Kafka 粘合剂健康指示器

Reactor Kafka 绑定器提供了一个HealthIndicator调用 Spring Boot Actuator 时将使用的实现health端点。 当 Spring Boot 执行器依赖于类路径时,可以使用 Binder 健康指示器启用 Reactor Kafka 绑定器。 此运行状况指示器提供有关基于活页夹的应用程序状态的信息,即当前是否UPDOWN、应用程序正在使用的主题,以及有关绑定程序内部使用的消息生产者组件的各种详细信息。spring-doc.cadn.net.cn

Reactor Kafka Binder Health Indicator 已使用密钥reactorKafka内部由框架。 因此,可以通过如下图所示的方式以编程方式查询它。spring-doc.cadn.net.cn

CompositeHealthContributor compositeHealthContributor = context
			.getBean("bindersHealthContributor", CompositeHealthContributor.class);
ReactorKafkaBinderHealthIndicator healthIndicator = (ReactorKafkaBinderHealthIndicator) compositeHealthContributor.getContributor("reactorKafka");
Health health = healthIndicator.health();