栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Canal与Kafka整合实现MySQL实时同步之经典案例

Canal与Kafka整合实现MySQL实时同步之经典案例

环境准备:

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消费数据如下:

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/711842.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号