ApsaraDB for OceanBase：建立 RocketMQ 資料來源

前提條件

• 資料轉送已具備雲資源存取權限。詳情請參見 資料轉送遷移角色授權。

• 已在 RocketMQ 執行個體中建立 Group。詳情請參見 建立 Group。

• 已在 RocketMQ 執行個體中建立名稱為 oms_test_topic 的 Topic。

使用限制

• 資料轉送支援 RocketMQ 執行個體 V4.x 和 V5.x，包含商業版和社區版。

• VPC 內自建 RocketMQ 執行個體對於網路的處理：安裝 RocketMQ 執行個體的 ECS 的安全性群組需要添加對應 VPC 的網段，放開 RocketMQ 執行個體的 namesvr 和 broker 的所有連接埠。

操作步驟

1. 登入 OceanBase 管理主控台。

2. 在左側導覽列，單擊 資料轉送 > 資料來源管理。

3. 在 資料來源列表 頁面，單擊右上方的 建立資料來源。

4. 在 建立資料來源 對話方塊中，選擇 資料來源類型 為 RocketMQ。

5. 配置各項參數。從 執行個體類型 下拉式清單選擇不同的 執行個體類型 後，下方會自動顯示對應的表單。

   執行個體類型	參數	描述
   阿里雲 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。
   	備忘（可選）	資料來源的備忘資訊。

6. 單擊 測試連接，測試資料轉送和資料庫的網路連接。

   重要

   如果您未建立 oms_test_topic，將無法通過測試連接。

7. 測試連接通過後，單擊 確定。

建立 Group

建立 RocketMQ 資料來源時，您需要提前建立 defaultGroup，才能夠通過測試連接。

阿里雲 RocketMQ 執行個體

1. 進入 RocketMQ 執行個體的詳情頁面。

   1. 登入 訊息佇列 RocketMQ 版管理主控台。

   2. 在左側導覽列，單擊 執行個體列表。

   3. 在 執行個體列表 頁面，單擊目標執行個體名稱，進入 執行個體詳情 頁面。

2. 在左側導覽列，單擊 Group 管理。

3. 在 Group 管理 頁面，單擊 建立 Group，並配置各項參數。

   不同版本的 RocketMQ 執行個體，建立 Group 時需要配置的參數也不同。詳情請參見 4.0 執行個體文檔。

   重要

   建立 Group 時，Group ID 必須設定為 defaultGroup。

4. 配置完成後，單擊 確定。

5. 建立 Topic：oms_test_topic。

   1. 在目標執行個體的詳情頁面，單擊左側導覽列的 Topic 管理。

   2. 在 Topic 管理 頁面，單擊 建立 Topic。

   3. 在 建立 Topic 對話方塊，配置各項參數。

      參數	描述
      名稱	oms_test_topic。
      付費方式	僅 RocketMQ 執行個體 4.x 版本建立 Topic 時顯示該參數，且僅支援 隨用隨付。
      訊息類型	RocketMQ 執行個體 4.x 版本支援 普通訊息、事務訊息、分區順序訊息、全域順序訊息 和 定時/延時訊息。 RocketMQ 執行個體 5.x 版本支援 普通訊息、順序訊息、定時/延時訊息 和 事務訊息。
      描述	長度不能超過 128 個字元。

   4. 配置完成後，單擊 確定。

VPC 內自建 RocketMQ 執行個體

1. 進入機器的 RocketMQ 目錄，執行下述命令，即可建立 defaultGroup。

   ./bin/mqadmin updateSubGroup -n 10.10.10.1:2882 -c DefaultCluster -g defaultGroup

2. 執行下述命令，建立 Topic：oms_test_topic。

   ./bin/mqadmin updateTopic -t oms_test_topic -n 10.10.10.1:2882 -c DefaultCluster