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