|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 spring-cloud-stream 4.3.0！ |
Reactor Kafka 粘合剂健康指示器
Reactor Kafka 绑定器提供了一个HealthIndicator调用 Spring Boot Actuator 时将使用的实现health端点。
当 Spring Boot 执行器依赖于类路径时，可以使用 Binder 健康指示器启用 Reactor Kafka 绑定器。
此运行状况指示器提供有关基于活页夹的应用程序状态的信息，即当前是否UP或DOWN、应用程序正在使用的主题，以及有关绑定程序内部使用的消息生产者组件的各种详细信息。
Reactor Kafka Binder Health Indicator 已使用密钥reactorKafka内部由框架。
因此，可以通过如下图所示的方式以编程方式查询它。
CompositeHealthContributor compositeHealthContributor = context
.getBean("bindersHealthContributor", CompositeHealthContributor.class);
ReactorKafkaBinderHealthIndicator healthIndicator = (ReactorKafkaBinderHealthIndicator) compositeHealthContributor.getContributor("reactorKafka");
Health health = healthIndicator.health();