private method

依据kafka集群ID删除数据 @param clusterPhyId kafka集群ID

删除ACL

删除KafkaUser

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

Drain all the calls from newCalls into pendingCalls. This function holds the lock for the minimum amount of time, to avoid blocking users of AdminCli

Returns a future which yields just the errors which occurred. If this future yields a non-empty collection, it is very likely that elements are missi

执行迁移任务 @param executeReassignParam 参数 @return

Generate the client id based on the configuration. @param config The configuration @return The client id

生成迁移计划 @param clusterPhyId 物理集群ID @param topicName Topic名称 @param partitionIdList 分区ID @param brokerIdList BrokerID @param enableRackAwareness 是否rack感

生成副本扩缩计划 @param clusterPhyId 物理集群ID @param topicName Topic名称 @param newReplicaNum 新的副本数 @param brokerIdList BrokerID @return

private method

更新子任务中扩展字段的数据

获取Broker配置详细信息 @param clusterPhyId 物理集群ID @param brokerId brokerId @return