事件网格 EG-校验专业版事件流作业:请求参数
请求参数
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
X-Auth-Token |
是 |
String |
用户Token。通过调用 IAM 服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 |
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
cluster_id |
是 |
String |
集群ID |
source_config |
否 |
EventRouterJobSource object |
专业版事件流作业源端配置 |
sink_config |
否 |
EventRouterJobSink object |
专业版事件流作业目标端配置 |
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
source_kafka |
否 |
KafkaParameters object |
kafka配置 |
source_rocketmq |
否 |
RocketmqParameters object |
rocketmq配置 |
source_dcs |
否 |
DcsParameters object |
dcs配置 |
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
sink_kafka |
否 |
KafkaParameters object |
kafka配置 |
sink_rocketmq |
否 |
RocketmqParameters object |
rocketmq配置 |
sink_dcs |
否 |
DcsParameters object |
dcs配置 |
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
config_type |
是 |
String |
实例类型 CLOUD:云服务DMS kafka实例 |
region |
是 |
String |
区域ID |
project_id |
是 |
String |
资源空间ID |
instance_id |
否 |
String |
kafka实例ID,配置类型选择CLOUD时必填 |
cluster_alias |
是 |
String |
kafka集群别名 |
address |
否 |
String |
kafka地址 |
authenticate_mode |
否 |
String |
kafka认证方式 |
sasl_mechanism |
否 |
String |
SASL认证机制 |
user_name |
否 |
String |
用户名,开启SASL_SSL时必填 |
password |
否 |
String |
用户密码,开启SASL_SSL时必填 |
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
config_type |
是 |
String |
实例类型。 CLOUD:云服务DMS Rocketmq实例 |
region |
是 |
String |
区域id |
project_id |
是 |
String |
资源空间ID |
instance_id |
否 |
String |
rocketmq实例ID,配置类型选择CLOUD时必填 |
cluster_alias |
是 |
String |
rocketmq集群别名 |
address |
否 |
String |
rocketmq地址 |
ssl_open |
否 |
String |
rocketmq SSL开关 true: 开启 false: 关闭 |
acl_open |
否 |
Boolean |
rocketmq ACL开关 true: 开启 false: 关闭 |
user_name |
否 |
String |
用户名,开启ACL时必填 |
password |
否 |
String |
用户密码,开启ACL时必填 |
参数 |
是否必选 |
参数类型 |
描述 |
---|---|---|---|
config_type |
是 |
String |
实例类型 CLOUD:云服务D CS 实例 |
region |
是 |
String |
区域id |
project_id |
是 |
String |
资源空间ID |
instance_id |
否 |
String |
dcs实例ID,配置类型选择CLOUD时必填 |
address |
否 |
String |
dcs地址 |
password |
否 |
String |
用户密码 |