修改 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
最后编辑:Jeebiz 更新时间:2024-07-10 22:56