健康指標

健康指示器需要依賴項 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 文件

健康指示器為每個流執行緒的元資料提供以下詳細資訊

  • 執行緒名稱

  • 執行緒狀態:CREATEDRUNNINGPARTITIONS_REVOKEDPARTITIONS_ASSIGNEDPENDING_SHUTDOWNDEAD

  • 活動任務:任務 ID 和分割槽

  • 備用任務:任務 ID 和分割槽

預設情況下,只顯示全域性狀態 (UPDOWN)。要顯示詳細資訊,屬性 management.endpoint.health.show-details 必須設定為 ALWAYSWHEN_AUTHORIZED。有關健康資訊的更多詳細資訊,請參見 Spring Boot Actuator 文件

如果所有已註冊的 Kafka 執行緒都處於 RUNNING 狀態,則健康指示器的狀態為 UP

由於 Kafka Streams binder 中有三個獨立的 binder(KStreamKTableGlobalKTable),它們都將報告健康狀態。當啟用 show-details 時,報告的一些資訊可能冗餘。

當同一個應用程式中存在多個 Kafka Streams 處理器時,將為所有這些處理器報告健康檢查,並按 Kafka Streams 的應用程式 ID 進行分類。

© . This site is unofficial and not affiliated with VMware.