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();