Health Indicator

运行状况指示器需要依赖项 spring-boot-starter-actuator。对于 maven 使用：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

Spring Cloud Stream Kafka 流绑定程序提供了一个健康指示符，用来检查基础流线程的状态。Spring Cloud Stream 定义了一个属性 management.health.binders.enabled 以启用健康指示符。参见 Spring Cloud Stream documentation。

运行状况指示器为每个流线程的元数据提供以下详细信息：

  • Thread name

  • 线程状态：CREATED，RUNNING，PARTITIONS_REVOKED，PARTITIONS_ASSIGNED，PENDING_SHUTDOWN 或 DEAD

  • 活动任务：任务 ID 和分区

  • 备用任务：任务 ID 和分区

默认情况下，只有全局状态可见（UP`或 `DOWN）。要显示详细信息，必须将属性 management.endpoint.health.show-details`设置为 `ALWAYS`或 `WHEN_AUTHORIZED。有关运行状况信息的更多详细信息，请参阅 Spring Boot Actuator documentation。

如果所有注册的 Kafka 线程处于 RUNNING 状态，则运行状况指示器的状态为 UP。

由于 Kafka Streams 绑定中有三个单独的绑定 (KStream、KTable 和 GlobalKTable)，它们都会报告运行状况状态。启用 show-details 时，报告的部分信息可能冗余。

当同一应用程序中存在多个 Kafka Streams 处理器时，将报告所有处理器的运行状况检查，并将按照 Kafka Streams 的应用程序 ID 对其进行分类。