|
该版本仍在开发中，尚未被视为稳定。对于最新稳定版本，请使用 spring-cloud-stream 5.0.0！ |
反应堆卡夫卡束剂健康指示器
反应堆卡夫卡结合剂提供了健康指标在调用Spring Boot执行器时将使用的实现健康端点。
当 Spring Boot 执行器依赖于类路径时，可以启用 Reactor Kafka 绑定器并设置绑定器健康指示器。
该健康指示器提供基于活页夹的应用程序状态信息，即当前状态向上或下应用程序使用的主题，以及绑定器内部使用的消息生成组件的各种细节。
反应堆卡夫卡活页夹健康指示器与密钥一起注册反应堆卡夫卡内部则由框架控制。
因此，它可以按程序方式查询，如下所示。
CompositeHealthContributor compositeHealthContributor = context
.getBean("bindersHealthContributor", CompositeHealthContributor.class);
ReactorKafkaBinderHealthIndicator healthIndicator = (ReactorKafkaBinderHealthIndicator) compositeHealthContributor.getContributor("reactorKafka");
Health health = healthIndicator.health();