路由到云消息队列 RocketMQ 版（位点重置）

前提条件

• 开通事件总线EventBridge并授权。

• 创建云消息队列RocketMQ 5.x系列实例或云消息队列RocketMQ 4.x系列实例。

• 创建云消息队列RocketMQ 5.x系列实例的Topic或4.x系列实例的Topic。

• （可选）为云消息队列RocketMQ 5.x系列实例添加标签或为4.x系列实例添加标签。

• （可选）创建云消息队列RocketMQ 5.x系列实例的Group或4.x系列实例的Group。

操作步骤

1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
2. 在顶部菜单栏，选择地域，然后单击创建事件流。

3. 在创建事件流面板，设置任务名称和描述，配置以下参数。

   • 任务创建

     1. 在Source（源）、Filtering（过滤）、Transform（转换）配置向导，设置事件过滤、转换规则，单击下一步。事件转换的配置说明，请参见使用函数计算实现消息数据清洗。

     2. 在Sink（目标）配置向导，选择服务类型为消息队列RocketMQ版（位点重置），配置以下参数，然后单击保存。

        参数	说明	示例
        InstanceType	选择RocketMQ实例版本。支持以下两个版本： RocketMQ 4.x RocketMQ 5.x	RocketMQ 5.x
        InstanceId	选择将消息路由到云消息队列 RocketMQ实例。	rmq-cn-77845****
        Topic	配置消息路由到云消息队列 RocketMQ实例的Topic。支持以下三种配置方式： 部分事件：如果您选择部分事件类型，通过JSONPath从事件中提取字段值作为目标Topic。 固定值：如果您选择固定值类型，需要在对应的文本框中输入Topic名称，所有事件均投递至该Topic。 模版：如果您现在模版类型，需要您自定义变量和模板，事件总线将会按照模板定义的内容生成Topic名称。	部分事件 $.data
        Group	配置云消息队列 RocketMQ实例的Group，用于管理消费位点。支持以下三种配置方式： 部分事件：如果您选择部分事件类型，事件总线通过JSONPath提取Group名称。 固定值：如果您选择固定值类型，需要在对应的文本框中输入所需Group名称。 模版：如果您现在模版类型，需要您自定义变量和模板，事件总线将会按照模板定义的内容生成Group名称。	部分事件 $.data
        ConsumeTimestamp	配置消息消费的时间戳，支持以下三种配置方式： 部分事件：如果您选择部分事件类型，事件总线通过JSONPath中已有的时间戳字段作为消费时间。 固定值：如果您选择固定值类型，需要在对应的文本框中输入所需消费时间戳。 模版：如果您现在模版类型，需要您自定义变量和模板，事件总线将会按照模板定义的内容生成消费时间戳。	部分事件 $.data

   • 任务属性

     设置事件流的重试策略及死信队列。更多信息，请参见重试和死信。

结果验证

1. 登录云消息队列 RocketMQ 版控制台，在顶部菜单栏，选择地域。

2. 在左侧导航栏，单击实例列表。

3. 在实例列表页面，找到目标实例，在其操作列，单击详情。

4. 在左侧导航栏，单击Topic 管理，然后单击目标Topic名称。

5. 在Topic详情页面，单击消息查询页签，配置查询方式和时间范围，单击查询。