配置好資料來源是建立資料移轉或資料同步任務的前提。本文為您介紹如何在資料轉送中建立 RocketMQ 資料來源。
安全風險提醒
使用 OceanBase Data Transmission Service，您可以選擇自動添加或手動添加 OceanBase Data Transmission Service的公網 IP 位址段，但可能存在安全風險。一旦使用本產品代表您已理解和確認其中可能存在的安全風險，並且您需要採取基本的安全防護措施，包括但不限於加強帳號密碼的複雜度、限制各網段開放的連接埠號碼、內部 API 採用鑒權方式進行通訊，或者定期檢查並限制無需訪問的 IP 位址段。
OceanBase Data Transmission Service會根據業務需求和安全風險等因素對自動添加的白名單或安全性群組進行調整操作（增加或刪除），請勿將白名單或安全性群組中的 IP 位址段應用於非 OceanBase Data Transmission Service的業務需求。如果因為您將其應用於其他業務需求導致的問題，不在 OceanBase Data Transmission Service的 SLA 保障範圍內。OceanBase Data Transmission Service自動或手動添加的白名單或安全性群組，請參見 OceanBase Data Transmission Service 添加白名單 模組的文檔。
前提條件
資料轉送已具備雲資源存取權限。詳情請參見 資料轉送遷移角色授權。
已在 RocketMQ 執行個體中建立 Group。詳情請參見 建立 Group。
已在 RocketMQ 執行個體中建立名稱為
oms_test_topic的 Topic。
使用限制
資料轉送支援 RocketMQ 執行個體 V4.x 和 V5.x，包含商業版和社區版。
VPC 內自建 RocketMQ 執行個體對於網路的處理：安裝 RocketMQ 執行個體的 ECS 的安全性群組需要添加對應 VPC 的網段，放開 RocketMQ 執行個體的 namesvr 和 broker 的所有連接埠。
操作步驟
登入 OceanBase 管理主控台。
在左側導覽列，單擊 資料轉送 > 資料來源管理。
在 資料來源列表 頁面，單擊右上方的 建立資料來源。
在 建立資料來源 對話方塊中，選擇 資料來源類型 為 RocketMQ。
配置各項參數。從 執行個體類型 下拉式清單選擇不同的 執行個體類型 後，下方會自動顯示對應的表單。
執行個體類型
參數
描述
阿里雲 RocketMQ 執行個體
執行個體列表
從下拉式清單中選擇已建立的阿里雲 RocketMQ 執行個體。
VPC 內自建 RocketMQ 執行個體
VPC
從下拉式清單中選擇使用者申請公用雲端 VPC 的唯一 ID。
交換器
交換器（vSwitch）是組成Virtual Private Cloud 的基礎網路模組，用於串連不同的雲資源執行個體。詳情請參見 交換器概述。
共有參數
公網 RocketMQ 執行個體中包含所有共有參數
資料來源標識
建議使用中文、數字和字母的組合。名稱中不能包含空格，長度不得超過 32 個字元。
RocketMQ 存取點資訊
RocketMQ 的 <IP>:PORT 或者<網域名稱>:PORT。
AccessKey（可選）
您在阿里雲帳號管理主控台中建立的 AccessKey ID，用於身份認證。
您可以將滑鼠移至上方至頁面右上方的帳戶圖片，單擊 AccessKey 管理，查看 AccessKey ID。
SecretKey（可選）
您在阿里雲帳號管理主控台中建立的 AccessKey Secret，用於身份認證。
AccessKey Secret 只在建立時顯示，不支援查看，請妥善保管。建立詳情請參見 建立AccessKey。
備忘（可選）
資料來源的備忘資訊。
單擊 測試連接，測試資料轉送和資料庫的網路連接。
重要如果您未建立
oms_test_topic，將無法通過測試連接。測試連接通過後，單擊 確定。
建立 Group
建立 RocketMQ 資料來源時，您需要提前建立 defaultGroup，才能夠通過測試連接。
阿里雲 RocketMQ 執行個體
進入 RocketMQ 執行個體的詳情頁面。
在左側導覽列，單擊 執行個體列表。
在 執行個體列表 頁面，單擊目標執行個體名稱，進入 執行個體詳情 頁面。
在左側導覽列，單擊 Group 管理。
在 Group 管理 頁面，單擊 建立 Group，並配置各項參數。
不同版本的 RocketMQ 執行個體，建立 Group 時需要配置的參數也不同。詳情請參見 4.0 執行個體文檔。
重要建立 Group 時，Group ID 必須設定為 defaultGroup。
配置完成後，單擊 確定。
建立 Topic：oms_test_topic。
在目標執行個體的詳情頁面，單擊左側導覽列的 Topic 管理。
在 Topic 管理 頁面，單擊 建立 Topic。
在 建立 Topic 對話方塊，配置各項參數。
參數
描述
名稱
oms_test_topic。
付費方式
僅 RocketMQ 執行個體 4.x 版本建立 Topic 時顯示該參數，且僅支援 隨用隨付。
訊息類型
RocketMQ 執行個體 4.x 版本支援 普通訊息、事務訊息、分區順序訊息、全域順序訊息 和 定時/延時訊息。
RocketMQ 執行個體 5.x 版本支援 普通訊息、順序訊息、定時/延時訊息 和 事務訊息。
描述
長度不能超過 128 個字元。
配置完成後，單擊 確定。
VPC 內自建 RocketMQ 執行個體
商業版和社區版 VPC 內自建 RocketMQ 執行個體建立 Group 和 Topic 的方式相同。
進入機器的 RocketMQ 目錄，執行下述命令，即可建立 defaultGroup。
./bin/mqadmin updateSubGroup -n 10.10.10.1:2882 -c DefaultCluster -g defaultGroup執行下述命令，建立 Topic：oms_test_topic。
./bin/mqadmin updateTopic -t oms_test_topic -n 10.10.10.1:2882 -c DefaultCluster