Canal的安装和简单使用

目录

1、Mysql安装

1.1 Mysql安装

1.2 用户创建

2、安装Canal

2.1下载

2.2 解压

2.3 修改canal的主配置⽂件canal.properties

2.4 修改canal的实例配置⽂件example/instance.propertie

2.5 启动Canal

2.6 启动Kafka客户端读取Kafka中的数据

---

1、Mysql安装

1.1 Mysql安装

1.2 用户创建

CREATE USER canal IDENTIFIED BY 'canal123';GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';FLUSH PRIVILEGES;CREATE DATABASE doit

2、安装Canal

2.1下载

Releases · alibaba/canal · GitHub

2.2 解压

2.3 修改canal的主配置⽂件canal.properties

#canal跟kafka整合，将数据发送到kafkacanal.serverMode = kafka#指定kafka broker地址canal.mq.servers = node-1.51doit.cn:9092,node-2.51doit.cn:9092,node-3.51doit.cn:9092#数据发送kafka失败重试次数canal.mq.retries = 10

2.4 修改canal的实例配置⽂件example/instance.propertie

#mysql数据库的地址canal.instance.master.address=127.0.0.1:3306#mysql用户名canal.instance.dbUsername=canal#mysql密码canal.instance.dbPassword=canal123#注释掉使用默认的topic(将数据写入到默认的Topic)#canal.mq.topic=example# dynamic topic route by schema or table regex#将doit的数据库的user表发送到kafka的user1的topiccanal.mq.dynamicTopic=topic1:db1\\.tb1,user1:doit\\.user

2.5 启动Canal

bin/startup.sh

2.6 启动Kafka客户端读取Kafka中的数据

 /bigdata/kafka_2.12-2.4.1/bin/kafka-console-consumer.sh --bootstrap-server node-1.51doit.cn:9092,node-2.51doit.cn:9092,node-3.51doit.cn:9092 --topic topic1 --from-beginning