kafka集群的健康状态检测方法、系统、装置及介质

摘要

本申请公开了一种kafka集群的健康状态检测方法、系统、装置及介质，涉及数据处理领域。该方案中，每隔预设时间段获取待检测的kafka集群的环境信息，以确定kafka集群的配置节点数量；通过zookeeper集群获取待检测的kafka集群中的当前节点数量；通过判断配置节点数量与当前节点数量是否相同，以确定是否存在处于掉线状态的节点；若存在，则分别对所有节点进行检测，以定位处于掉线状态的节点。可见，本申请中可以自动实现对kafka集群的故障检测和定位，无需人工手动干预，缩短了检测时长，避免由于人工导致的出错率高。