获取所有的连接器名称列表

DB-GroupTopic相关接口

从ES查询指标 @param clusterId 集群ID @param dto 查询dto @return

根据索引模板获取所有的索引

获取全部集群 clusterId 中类型为 type 的指标，不论支持不支持 @param clusterId @param type @return

获取 km 集群所有部署的 host 节点 @return

获取 按照Group&Topic维度进行聚合 后的指标 @param clusterPhyId 物理集群ID @param groupTopicList GroupTopic列表 @param metricNames 指标列表 @param aggType 聚合类型：avg、max、min、sum

获取指定集群，指定指标，一段时间内的值

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

从DB获取未存活的Broker列表

从DB获取分区信息

private method

private method

获取Topic维度最新的一条指标

获取每个 metric 的 topN 个 topic 的指标，如果获取不到 topN 的topics, 则默认返回 defaultTopics 的指标

从Kafka获取数据

获取当前用户设置的用于展示的指标配置 @param clusterId @param type @param operator @return

private method

private method

private method

private method

Create a new metadata call.

Choose nodes for the calls in the pendingCalls list. @param now The current time in milliseconds. @return The minimum time unt

仅合并Topic的元信息部分，业务信息和配置信息部分不合并

private method

修改集群 @param clusterPhyPO 集群信息 @param operator 操作人 @throws ParamErrorException 参数错误 @throws DuplicateException 数据重复异常 @throws NotExistException 集群不存在 @

修改KafkaUser

修改KafkaUser

是否重试 @param e 异常 @return