健康指標
健康指示器需要依賴項 spring-boot-starter-actuator。對於 Maven,請使用
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
Spring Cloud Stream Kafka Streams Binder 提供了一個健康指示器來檢查底層流執行緒的狀態。Spring Cloud Stream 定義了一個屬性 management.health.binders.enabled 來啟用健康指示器。參見 Spring Cloud Stream 文件。
健康指示器為每個流執行緒的元資料提供以下詳細資訊
-
執行緒名稱
-
執行緒狀態:
CREATED、RUNNING、PARTITIONS_REVOKED、PARTITIONS_ASSIGNED、PENDING_SHUTDOWN或DEAD -
活動任務:任務 ID 和分割槽
-
備用任務:任務 ID 和分割槽
預設情況下,只顯示全域性狀態 (UP 或 DOWN)。要顯示詳細資訊,屬性 management.endpoint.health.show-details 必須設定為 ALWAYS 或 WHEN_AUTHORIZED。有關健康資訊的更多詳細資訊,請參見 Spring Boot Actuator 文件。
如果所有已註冊的 Kafka 執行緒都處於 RUNNING 狀態,則健康指示器的狀態為 UP。 |
由於 Kafka Streams binder 中有三個獨立的 binder(KStream、KTable 和 GlobalKTable),它們都將報告健康狀態。當啟用 show-details 時,報告的一些資訊可能冗餘。
當同一個應用程式中存在多個 Kafka Streams 處理器時,將為所有這些處理器報告健康檢查,並按 Kafka Streams 的應用程式 ID 進行分類。