Create a RocketMQ data source

You must configure data sources before you create a data migration project. Before you start data migration, you can add a RocketMQ instance as the source or destination data source. This topic describes how to create a RocketMQ data source in OceanBase Migration Service (OMS).

Prerequisites

• You have obtained the IP address and port number of the related database.

• You have created a database user for data migration.

  We recommend that you create a dedicated database user for the data migration project and grant the required data operation privileges to the user. For more information, see Create a database user.

• You have created a topic named oms_test_topic in the RocketMQ instance.

Procedure

1. Log on to the OMS console.

2. In the left-side navigation pane, click Data Source Management.

3. On the Data Source Management page, click New Data Source in the upper-right corner.

   

4. In the New Data Source dialog box, select RocketMQ for Data Source Type.

5. Configure the following parameters.

   Parameter	Description
   Data Source Identifier	We recommend that you set it to a combination of digits and letters. It must not contain any spaces and cannot exceed 32 characters in length. Notice The data source identifier must be globally unique in OMS.
   Region	Select the region where the data source resides from the drop-down list. The region is the value that you set for the cm_region parameter when you deploy OMS. Notice This parameter is displayed only when multiple regions are available. Make sure that the mappings between the data source and the region are consistent. Otherwise, the migration and synchronization performance can be poor.
   RocketMQ Endpoint Information	The format is :port number or :port number.
   AccessKey (Optional)	The AccessKey ID that you created in the Resource Access Management (RAM) console for identity authentication.
   SecretKey (Optional)	The AccessKey secret that you created in the RAM console for identity authentication.
   Remarks (Optional)	Additional information about the data source.

6. Click Test Connection to test the network connection between OMS and the source database.

   Notice

   If you do not create the oms_test_topic topic, the test will fail.

7. After the test is passed, click OK.