利用debezium、kafka connector 解析 mysql binlog 到 kafak
一、需求
需要搭建一个可以自动监听MySQL数据库变化,并将变化的数据捕获,发送至指定主题的数据监控(审计)平台
二、所需技术
debezium :https://debezium.io/documentation/reference/1.6/tutorial.html
kafka:http://kafka.apache.org/
zookeeper : http://zookeeper.apache.org/
mysql 5.7/8: https://www.mysql.com/
三、环境准备
3.1 数据库
因监听基础是基于 mysql binlog
,需要开启binlog
。
语句方式:
set global binlog_format=ROW;
还没有评论,来说两句吧...