全部產品
Search
文件中心

ApsaraDB for OceanBase (Deprecated):建立 RocketMQ 資料來源

更新時間:Jul 01, 2025

配置好資料來源是建立資料移轉或資料同步任務的前提。本文為您介紹如何在資料轉送中建立 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 執行個體 智能身份識別 存取控制中的 內網免身份識別。

    RocketMQ 執行個體預設使用 智能身份識別 存取控制類型,該類型預設對內網進行鑒權。如果未開啟 內網免身份識別,則 VPC 存取點需要使用者名稱和密碼才能通過資料來源測試連接。

使用限制

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

操作步驟

  1. 登入 OceanBase 管理主控台。

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

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

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

  5. 配置各項參數。

    參數

    描述

    執行個體類型

    目前僅支援 阿里雲 RocketMQ 執行個體。

    資料來源標識

    建議使用中文、數字和字母的組合。名稱中不能包含空格,長度不得超過 32 個字元。

    是否跨阿里雲主帳號

    資料轉送支援對不同阿里雲主帳號下的執行個體配置資料移轉或資料同步任務,實現跨阿里雲主帳號的資料移轉或資料同步。

    您可以根據業務需求選擇是否勾選。如果勾選,請輸入對方阿里雲主帳號。如果不具備該主帳號的許可權,請先申請授權。授權詳情請參見 申請跨帳號授權。

    執行個體列表

    從下拉式清單中選擇已建立的阿里雲 RocketMQ 執行個體。

    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,才能夠通過測試連接。

  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. 配置完成後,單擊 確定。