获取数据同步任务配置

最近更新时间:2019-07-22 13:16:15

我的收藏

1. 接口描述

接口请求域名:ckafka.api.qcloud.com 本接口(GetConnectorConfigs)用于查询数据同步任务配置。

2. 输入参数

以下请求参数列表仅列出了接口请求参数,其它参数见 公共请求参数 页面。
参数名称
必选
类型
描述
connectorId
String
connectorId,根据该参数指定 connector 过滤。

3. 输出参数

参数名称
类型
描述
connector.class
String
执行该任务的 class 名称。
dest.instance
String
目的实例名称。
topic.config
String
主题配置。
connector.version
String
connector 版本。
src.instance
String
源实例。
offset.reset
String
任务同步启动时候的 offset 设置,可参考 创建数据同步 服务接口说明。
source.broker
String
源实例访问 broker 地址和端口。
keep.partition
String
源和目的 topic 的 partition 数量是否要求保持一致。
true:保持一致;false:不一致。
name
String
connector 名称。
auto.create
String
是否开启主题自动创建。true 表示开启,false 表示不开启。

4. 示例

输入:
https://domain/v2/index.php?Action=GetConnectorConfigs&<公共请求参数>
输出:
{
"code":0,
"codeDesc":"Success",
"message":"ok",
"data":{
"connector.class":"com.tencent.ckafka.replicator.K2KSourceConnector",
"dest.instance":"ckafka-xxxxxx",
"topic.config":"{"test":{},"test1":{}}",
"connector.version":"0.10.2.1",
"src.instance":"ckafka-xxxxxxxx",
"offset.reset":"latest",
"source.broker":"10.14.211.55:6017",
"keep.partition":"true",
"name":"connector-ckafka-xxxxxxxx",
"auto.create":"false"
}
}