Reactor Kafka Binder 健康指示器
Reactor Kafka binder 提供了 HealthIndicator
實作,當調用 Spring Boot Actuator health
端點時將會使用。當 Spring Boot actuator 相依性在 classpath 上時,可以使用 binder 健康指示器啟用 Reactor Kafka binder。此健康指示器提供了關於基於 binder 的應用程式狀態的資訊,亦即,目前是 UP
還是 DOWN
、應用程式正在使用的主題,以及 binder 內部使用的訊息生產者元件的各種詳細資訊。
Reactor Kafka Binder 健康指示器在框架內部以金鑰 reactorKafka
註冊。因此,可以如下所示以程式方式查詢。
CompositeHealthContributor compositeHealthContributor = context
.getBean("bindersHealthContributor", CompositeHealthContributor.class);
ReactorKafkaBinderHealthIndicator healthIndicator = (ReactorKafkaBinderHealthIndicator) compositeHealthContributor.getContributor("reactorKafka");
Health health = healthIndicator.health();