跳到主要内容

RabbitMQ

必要条件​

必要条件说明
账号权限分配的账号请保证有对消息系统元数据查询和读写权限，需要管理员账号登录 RabbitMQ 管理控制台打开相应权限

常用对端任务参数​

参数名称说明
ddlTopic指定的 DDL 发送的 Topic，该 Topic 会接收该同步任务的所有 DDL 消息

高级功能​

支持多种消息格式​

CloudCanal 写 RabbitMQ 支持以下多种消息格式：

  • CloudCanal Json：CloudCanal 默认的消息格式，解析数据库增量日志传输至 RabbitMQ，支持批量消息传输。
  • Canal Json：对于 Canal 的兼容格式，数据存储格式为 Canal Json。

全库同步​

MySQL -> RabbitMQ 的同步链路支持全库同步模式。全库同步允许将源端多个表的数据全部映射到 RabbitMQ 的一个 Topic 中。操作方式如下：

  • 在任务创建过程的第一步，选择 MySQL 数据源后点击 高级设置->全库同步，对端选择 RabbitMQ 数据源然后选择默认 Topic，用于接收源端库下所有表的数据。

image.png

  • 后续任务创建过程则无需配置表映射

image.png