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"
}
}