对于最新稳定版本，请使用spring-cloud-stream 5.0.1！spring-doc.cadn.net.cn

Reactor Kafka绑定程序健康指示器

Reactor Kafka binder 提供了一个 HealthIndicator 实现，当调用 Spring Boot Actuator health 端点时将使用该实现。
当 Spring Boot actuator 依赖在类路径上时，可以启用 Reactor Kafka binder 的绑定器健康指标。
此健康指标提供了基于应用程序的绑定器状态信息，例如它是否当前处于 UP 或 DOWN 状态、应用程序正在使用的主题以及绑定器内部使用的消息生产组件的各种详细信息。spring-doc.cadn.net.cn

框架内部使用键reactorKafka注册了Reactor Kafka Binder健康指标。因此，可以按如下所示进行程序查询。spring-doc.cadn.net.cn

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