Canal配置多个实例以及将Mysql指定表的binlog导入指定的Kafka的Topic

进入Canal的conf目录

在这里插入图片描述

复制模板配置文件

 cp -r example/ Order
 cp -r example/ Orderdetail

在这里插入图片描述
修改canal.propertieswenjain

vim canal.properties

修改内容如下,指定输出模式为kafka

canal.serverMode = kafka

在这里插入图片描述
修改内容如下,绑定多个实例,多个实例用逗号分隔,实例名称为文件名

canal.destinations = Order,Orderdetail

在这里插入图片描述
然后修改每个实例下面的配置文件
在这里插入图片描述
修改Order实例下的配置文件

vim instance.properties

配置Mysql主机地址+IP,账号,免密
在这里插入图片描述
指定表名(库名.表名),Topic名称
在这里插入图片描述

修改Orderdetai实例下的配置文件

vim instance.properties

配置Mysql主机地址+IP,账号,免密
在这里插入图片描述
指定表名(库名.表名),Topic名称
在这里插入图片描述
使用指令启动canal,在canal目录下

bin/startup.sh

在这里插入图片描述

GitHub 加速计划 / ca / canal
28.21 K
7.57 K
下载
alibaba/canal: Canal 是由阿里巴巴开源的分布式数据库同步系统,主要用于实现MySQL数据库的日志解析和实时增量数据订阅与消费,广泛应用于数据库变更消息的捕获、数据迁移、缓存更新等场景。
最近提交(Master分支:1 个月前 )
1e5b8a20 - 21 天前
ff82fd65 21 天前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐