Reactor Kafka 绑定器健康指示器

Reactor Kafka Binder 提供了一个 HealthIndicator 实现，该实现将在调用 Spring Boot Actuator health 端点时使用。当 classpath 中存在 Spring Boot actuator 依赖项时，可以通过绑定器健康指示器启用 Reactor Kafka Binder。此健康指示器提供有关基于绑定器的应用程序状态的信息，即它当前是 UP 还是 DOWN，应用程序使用的主题，以及绑定器内部使用的消息生产者组件的各种详细信息。

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

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