修改 canal.properties 文件,配置输出到 RabbitMQ,有以下几处要改:

# tcp, kafka, rocketMQ, rabbitMQ, pulsarMQ
canal.serverMode = pulsarMQ

##################################################
#########               Pulsar         #############
##################################################
pulsarmq.serverUrl =
pulsarmq.roleToken =
pulsarmq.topicTenantPrefix =

接下来修改 instance.properties 文件:

# MySQL 地址 + 端口
canal.instance.master.address=host:port
canal.instance.dbUsername=xxxx
canal.instance.dbPassword=xxxx
# 对应到 RabbitMQ 的话是 Routing key
canal.mq.topic=canal-routing-key
作者:Jeebiz  创建时间:2023-07-11 20:41
最后编辑:Jeebiz  更新时间:2024-07-10 22:56