| 失效链接处理 |
|
Canal的安装和部署,与实践 PDF 下载
本站整理下载：
相关截图：
主要内容：
1.两个配置文件直接使用群里的进行替换，里边的端口号修改为自己的
Conf下的canal.properties，conf下的example/instance.properties
2.开启mysql的binlog写入功能
Vim /usr/my.cnf
加入
#打开binlog
log-bin=mysql-bin
# 选择ROW(行)模式
binlog-format=ROW
# 配置MySQL replaction需要定义，不要和canal的slaveId重复
server_id=1
3. 为canal配置 mysql slave的相关权限
create user 'canal'@'%' identified by 'Canal@123456';
grant SELECT, REPLICATION SLAVE, REPLICATION CLIENT on *.* to 'canal'@'%' identified by 'Canal@123456';
4.重启mysql server
Service mysql restart
5.启动zookeeper，kafka
6.创建kafka topic，开启消费者
bin/kafka-topics.sh --zookeeper hadoop101:2181 --create --replication-factor 1 -partitions 1 --topic example
bin/kafka-console-consumer.sh --topic example --from-beginning --bootstrap-server hadoop101:9092
7.开启canal
8.在mysql中创表，添加数据，查看kafka的消费者是否接收到json信息
|
| Java1234官方群25： | 
|
| Java1234官方群25： | 838462530 |
苏公网安备 32061202001004号
