|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 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 文档。
运行状况指示器的状态为UP如果注册的所有 Kafka 线程都在RUNNING州。 |
由于 Kafka Streams 绑定器中有三个单独的绑定器 （KStream,KTable和GlobalKTable），它们都将报告健康状态。
启用时show-details，报告的一些信息可能是多余的。
当同一应用程序中存在多个 Kafka Streams 处理器时，将报告所有处理器的运行状况检查，并按 Kafka Streams 的应用程序 ID 进行分类。