此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-stream 4.1.4! |
运行状况指示器
运行状况指示器需要依赖项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 Binder 中有三个单独的 Binder (KStream
,KTable
和GlobalKTable
),它们都会报告运行状况。
启用show-details
,则报告的某些信息可能是多余的。
当同一应用程序中存在多个 Kafka Streams 处理器时,将报告所有处理器的运行状况检查,并按 Kafka Streams 的应用程序 ID 进行分类。