获取集群 clusterPhyId 中每个 metric 的 topN 的 broker 在指定时间[startTime、endTime]区间内所有的指标 topN 按照[startTime, endTime] 时间段内最后一个值来排序

从Kafka获取存活的Broker列表

获取一批集群 clusterPhyIds 一段时间内 metrics 的指标值

获取[startTime,endTime]时间段内的groupName对应的topic&partition

从Kafka中获取消费组名称列表

获取集群 clusterPhyId 中每个 metric 的指定 connectClusters 在指定时间[startTime、endTime]区间内所有的指标

获取每个 metric 的 topN 个 connector 的指标，如果获取不到 topN 的 connectors, 则默认返回 defaultConnectorList 的指标

从ES中获取一段时间内聚合计算之后的指标线

private method

从Kafka获取分区信息

private method

获取 topic 最新的指标

@param clusterPhyId @param topics @param metric @param max @param startTime @param endTime @return

分页获取

Check whether a pending call can be assigned a node. Return true if the pending call was either transferred to the callsToSend collection or if the ca