如何正确编写 Kafka Streams 健康检查？

Question

Kafka 将在内部杀死任何未正确轮询的节点，但我们不希望坏节点保持运行状态，并且我们希望了解哪些节点正在工作，因此我们自然希望构建经典的健康检查。

构建健康检查的明显方法是使用，KafkaStream#state#isRunning但这完全是欺骗性的。如果与 Kafka 的底层网络连接发生故障，或者出现多种不会导致内部线程终止的情况中的任何一种，KafkaStreams即使日志到处抛出错误，它仍然会报告自身处于活动状态。有没有正确的方法可以了解 Kafka 流中发生的情况？在处理 Kafka 时，期望进行健全的健康检查是错误的做法吗？

需要明确的是，我不是在谈论 Kafka集群的健康检查，特别是 Streams 处理器节点。