1、安装配置好Canal,如果不会跳转到Canal安装与配置(保姆级教程)
2、安装配置好Kafka,如果不会跳转到Kafka安装和配置(保姆级教程)
3、安装配置好zookeeper,如果不会跳转到zookeeper集群搭建及启动脚本(三节点)(保姆级教程)
操作步骤:1、进入到canal目录下,执行命令./bin/startup.sh
2、启动zookeeper,zkServer.sh start
3、启动Kafkanohup kafka-server-start.sh /opt/soft/kafka211/config/server.properties &
创建主题
kafka-topics.sh --create --zookeeper 192.168.91.180:2181 --topic canalkfdemo --partitions 1 --replication-factor 1
开始消费数据,查看是否有数据(这时候肯定是没有数据的,因为我们还没有在MySQL进行操作)
kafka-console-consumer.sh --bootstrap-server 192.168.91.180:9092 --topic canalkfdemo --from-beginning
4、启动MySQL,使用第三方可视化工具来操作(navicat、dbeaver…)
创建数据库
create database canalstu; use canalstu;
创建表
create table student(
id int(8),
name varchar(32),
age int(8)
)
truncate table student;
插入数据,更新数据操作
insert into student values(2,'ls',19); update student set age=99 where id=2;
kafka消费数据如下:



