Reactor Kafka Binder 健康指示器

Reactor Kafka binder 提供了一个 HealthIndicator 实现，当调用 Spring Boot Actuator 的 health 端点时会使用它。当 Spring Boot actuator 依赖项在 classpath 中时，可以为 Reactor Kafka binder 启用 binder 健康指示器。这个健康指示器提供关于基于 binder 的应用状态信息，例如它当前是 UP（正常）还是 DOWN（宕机），应用正在使用的主题（topic），以及关于 binder 内部使用的消息生产者组件的各种详细信息。

Reactor Kafka Binder 健康指示器在框架内部以键 reactorKafka 注册。因此，可以按如下所示以编程方式查询它。

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