maxwell读取mysql binlog到kafka

本文主要是介绍maxwell读取mysql binlog到kafka，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

下载地址

https://maxwells-daemon.io/

解压压缩包

tar -zxvf maxwell-1.29.0.tar.gz -C /opt/module/

初始化maxwell元数据库

在mysql中为maxwell创建一个数据库

复制 config.properties.example 文件

cp config.properties.example config.properties

修改config.properties文件

producer=kafka
kafka.bootstrap.servers=master:9092# mysql login info
host=slave3
user=maxwell
password=maxwellkafka_topic=maxwell

启动maxwell

./maxwell --config /opt/module/maxwell/config.properties

若出现如下错误，则需要修改mysql时区为东8区

set global time_zone='+8:00'

这篇关于maxwell读取mysql binlog到kafka的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---