CreateEventStreaming - 创建一个事件流

地域 id。

队列名称。

是否开启 Base64 编码。默认为 true。

地域 ID。

消息队列 RabbitMQ 版实例的实例 ID。

消息队列 RabbitMQ 版实例的 Vhost 的名称。

消息队列 RabbitMQ 版实例的 Queue 的名称。

地域 ID。

实例 ID。

Topic 名称。

订阅该 Topic 的消费者所对应的 Group ID。

偏移量。

网络配置。 默认值 Default，VPC 网络是 PublicNetwork。

VPC ID。

虚拟交换机 ID。

安全组 ID。

消息体编解码格式：

• JSON
• Text
• Binary

地域 ID。

消息队列 RocketMQ 版的实例所属地域。

消息服务的主题。

消息的过滤标签。

消息的消费位点。取值说明如下：

• CONSUME_FROM_LAST_OFFSET：从最新位点开始消费。
• CONSUME_FROM_FIRST_OFFSET：从最早位点开始消费。
• CONSUME_FROM_TIMESTAMP：从指定时间点的位点开始消费。

默认值：CONSUME_FROM_LAST_OFFSET。

消息队列 RocketMQ 版的 Group ID。

时间戳。仅当参数 Offset 取值为 CONSUME_FROM_TIMESTAMP 时，该参数有效。

实例类型。取值说明如下：

• Cloud_4：阿里云 RocketMQ 4.0 版本实例（默认选项）
• Cloud_5：阿里云 RocketMQ 5.0 版本实例
• SelfBuilt：自建 Apache RocketMQ 集群

实例接入点。

实例用户名。

实例密码。

网络类型：

• PublicNetwork
• PrivateNetwork

消息过滤类型。

sql 过滤语句。

鉴权类型。

跨境任务 VPC ID。

跨境任务 vSwitchIds。

跨境任务安全组。

实例 VPC 信息。

实例交换机信息。

实例安全组信息。

实例网络信息：

• PublicNetwork
• PrivateNetwork

消息编码格式

• JSON
• Text
• Binary

地域 ID。

实例 ID。

消息的 Topic。

消息编码格式：

• JSON
• Text
• Binary

任务 id。

数据订阅通道的网络地址及端口号信息。

数据订阅通道的订阅 Topic。

消费组 ID。

消费组的账号。

消费组的账号密码。

消费位点，即 SDK 客户端消费第一条数据的时间戳，格式为 Unix 时间戳。

日志服务 SLS 的日志项目。

日志服务 SLS 的日志库。

起始消费位点，可以选择最早或最新位点，分别对应“begin”，“end”，也可以从指定时间开始消费，以秒为单位。

授权事件总线 EventBridge 使用此角色读取 SLS 日志内容时，需满足条件：在 RAM 控制台创建服务所使用的角色时，需要选择“阿里云服务”，并且“受信服务”需要选择“事件总线”。

地域 ID。

集群 id。

数据类型。

标签。

消息队列 Kafka 版的实例 ID。

OSS 资源 ZIP 包下载链接。

kafka 实例配置。

连接器参数。

授权事件总线 EventBridge 读取 OSS 文件的角色名称，要求该角色至少具有 OSS 的只读权限。

对象存储 OSS 中的存储空间名称。

文件路径前缀。

数据加载模式，single 表示单文档加载，element 表示分块加载。 取值：single/element 默认为 single

文档加载器。

分隔符，在分块加载模式下，以该分隔符作为文本的分块标识符，默认以换行符\n 作为分隔符。

目标服务类型为消息服务 MNS。

消息内容。

是否开启 Base64 编码。

目标服务类型为消息队列 RabbitMQ 版。

消息队列 RabbitMQ 版实例的 Vhost 的名称。

目标类型。

Exchange 模式。 仅当参数 TargetType 配置为 Exchange 时，需配置此参数。

消息的路由规则。 仅当参数 TargetType 配置为 Exchange 时，需配置此参数。

Queue 模式。 仅当参数 TargetType 配置为 Queue 时，需配置此参数。

消息内容。

消息 ID。

过滤属性。