java检测kafka连接状态