RocketMQ
Target DataSource：
RocketMQ
| Function | Description |
|---|---|
Incremental Data Sync | Allow subscribing to messages from the source Topic. |
Subscription Modification | Add, delete, or modify the subscribed topics. For more information, see Modify Subscription. |
Position Resetting | Reset positions by timestamp to consume the data in a past period again. |
Advanced Functions
| Function | Description |
|---|---|
Message Format | The following message formats are supported. See Message Format.
|
Limits
| Limit | Description |
|---|---|
Creating Tables in the Target in Advance | Only support automatic Topic creation for messages. |
Raw Message Format | Only support raw message replication from RocketMQ to RocketMQ, and Raw Message Format needs to be selected at both the Source and the Target. |
Prerequisites
| Prerequisite | Description |
|---|---|
Port Preparation | Allow the migration and sync node (Worker) to connect to the RocketMQ nodes. |
Parameters
| Parameter | Description |
|---|---|
schemaFormat | MQ message format. For more information, see Message Format. |
Tips: To modify the general parameters, see General Parameters and Functions.