利用debezium、kafka connector 解析 mysql binlog 到 kafak

电玩女神 2022-09-10 15:16 219阅读 0赞

一、需求

需要搭建一个可以自动监听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

语句方式:

  1. set global binlog_format=ROW;

发表评论

表情:
评论列表 (有 0 条评论,219人围观)

还没有评论,来说两句吧...

相关阅读

    相关 带你解析MySQL binlog

    前言: 我们都知道,binlog可以说是MySQL中比较重要的日志了,在日常学习及运维过程中,也经常会遇到。不清楚你对binlog了解多少呢?本篇文章将从binlog作用、b