最新の安定バージョンについては、spring-cloud-stream 4.3.0 を使用してください。

ヘルス指標

ヘルスインジケータには、依存関係 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 バインダー（KStream、KTable、GlobalKTable）には 3 つの個別のバインダーがあるため、それらすべてがヘルスステータスを報告します。show-details を有効にすると、報告される情報の一部が冗長になる場合があります。

同じアプリケーションに複数の Kafka Streams プロセッサーが存在する場合、それらすべてのヘルスチェックが報告され、Kafka Streams のアプリケーション ID によって分類されます。