离线同步任务支持RocketMQ数据源，支持该数据源的导入（Writer）。

使用前提

在使用之前需要在“项目配置-项目中心（新）-数据源管理”完成该类型数据源的登记并测试通过（可在控制台的用户手册中查看具体登记详情信息），以及获取该数据源类型或数据的读权限（配置入口在安全中心-项目下的具体成员或角色）。

RocketMQ作为数据去向

RocketMQ作为数据去向需要配置如下内容：

  • 数据源：选择RocketMQ和已经登记的RocketMQ数据源
  • Topic：填写topic
  • 生产者配置：默认配置参数如下，支持手动添加
    • suspendCurrentQueueTimeMillis：1000
    • pullBatchSize：32
    • maxReconsumeTimes：3
    • consumeMessageBatchMaxSize：32
    • pullThresholdForQueue：1000
    • consumeTimeout：15
    • pullThresholdSizeForQueue：100