添加集群 @param clusterPhyPO 集群信息 @param operator 操作人 @return @throws ParamErrorException 参数异常 @throws DuplicateException 数据重复异常 @throws AdminOperateExcep

删除

批量插入数据库 @param connectClusterId @param workerList

构建如下dsl语句 { "range": { "timestamp": { "gte": 1646984254883, "lte": 1646987854883 } } } }

转换dsl语句

The client id of the group member.

从Kafka获取指标

从Kafka获取分区指标

解析ZK地址 @see ConnectStringParser

The consumer group coordinator, or null if the coordinator is not known.

统计一段时间内，某个指标出现某个值的次数 @param clusterPhyId 集群ID @param groupName 消费组名称 @param term 指标 @param startTime 起始时间 @param endTime 结束时间 @return