本文主要是介绍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的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
