|
对于最新稳定版本，请使用spring-cloud-stream 5.0.1！ |
健康指标
健康指示器需要依赖项 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操作员文档。
健康指标的状态为 UP，如果所有Kafka线程注册状态为RUNNING。 |
由于Kafka Streams binder中有三个单独的Binder（KStream、KTable和GlobalKTable），所有这些Binder都会报告健康状态。
当启用show-details时，可能会报告一些冗余信息。
当同一应用中有多个Kafka Streams处理器存在时，将为所有处理器报告健康检查，并按Kafka Streams的应用程序ID进行分类。