spring-boot - 我们可以手动更改 Kafka Stream 的状态吗？

Question

我正在使用 Spring Boot 创建 Kafka Stream 应用程序。我用的是spring-kafka，现在我打算用Spring Actuator添加健康检查。

我已经为 Kafka Stream 实现了 HealthIndicator，它检查它的状态并输出详细信息，如果它不是CREATED或RUNNING. （仅供参考，与this question中的代码类似）

现在我想知道我是否可以测试这个实现。我可以手动更新 Kafka Stream 状态很好，但我不知道我们是否真的可以这样做。有人有什么想法吗？

标签： spring-bootapache-kafkaspring-kafkaspring-boot-actuator