Initiate a new call. This will fail if the AdminClient is scheduled to shut down. @param call The new call object. @param now The current

获取id @return

获取ES文档的主键key @return

注册版本兼容的执行方法，[minVersion,maxVersion) 是一个左闭右开的范围，即：minVersion<= kafkaClusterVersion < maxVersion @param action @param minVersion @param maxVersion @para

是空字符串或者空

为空

创建一个任务 1、校验任务内容是否合法 2、提交任务 @param job 任务数据 @return result

获取Kafka客户端 @param clusterPhyId 物理集群ID @return

版本号归一化 先考虑标准的kafka版本号，0.7.x\0.10.0.x\1.0.x\2.2.x.x @param version @return

对象转换工具 @param srcObj 元对象 @param tgtClass 目标对象类 @param <T> 泛型 @return 目标对象

Returns a future that yields either an exception, or the full set of consumer group listings. In the event of a failure, the future yields nothing bu

创建迁移任务