GET请求 @param url 请求地址 @param params 请求参数 @param resultType 返回类型 @param <T> 泛型T @return T

获取集群 clusterId 中 brokerId 最新的统计指标

获取BrokerLog-Dir信息

获取集群 clusterPhyId 中每个 metric 的指定 broker 在指定时间[startTime、endTime]区间内聚合计算(avg、max)之后的统计值

通过id获取任务 @param id 任务id @return TaskPO

获取集群 clusterId 最新的统计指标

获取集群 clusterPhyId 中每个 metric 在指定时间[startTime、endTime]区间内聚合计算(avg、max)之后的统计值

Connect-Cluster

获取Topic默认配置 @param clusterPhyId 物理集群ID @return

计算指标

Returns a {@code Call} object to fetch the coordinator for a consumer group id. Takes another Call parameter to schedule action that need to be taken

从Kafka中获取消费组详细信息

获取 job 的详细信息 @param jobId @return

获取按照Topic维度聚合的详情

获取 job 相关的 broker 节点流量信息 @param jobId @return

查询KafkaUser

Get or create a list value from a map. @param map The map to get or create the element from. @param key The key. @param <K> The key type. @para

private method

Partition

获取routing值 @return

获取 topic 最新的指标

获取 topic 所在 broker 最新的指标

获取Topic在具体Broker上最新的一个指标 @param clusterPhyId 物理集群ID @param brokerId brokerId @param topicName Topic名称 @param metricNameList 需获取指标列表 @return

查询对应指标的版本兼容项 @param version @param type @param itemName @return