路由到雲訊息佇列 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（转换）設定精靈，設定事件過濾、轉換規則，單擊下一步。事件轉換的配置說明，請參見使用Function Compute實現訊息資料清洗。

     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詳情頁面，單擊訊息查詢頁簽，配置查詢方式和时间范围，單擊查询。