默认情况下,所有就绪检查都托管在/ready上,而活动检查托管在/alive上。
如果akka服务无法连接到Kafka集群,那么该服务应该报告为不健康。
我们需要在akka中添加什么配置,以便在集群停机时运行状况端点可以报告为不健康?
即使集群宕机,当前服务也报告运行正常。它返回Ok
你需要更新你的healthcheck端点来调用Kafka API。
例如,您可以使用AdminClient.describeCluster()
,就像我在本PR中为Akka API所做的那样