什么是MaxWell？
MaxWell守护进程是读取MySQL的二进制日志，将更新操作写入到消息队列，例如Kafka，RabbitMQ，Redis的订阅发布的应用。
官网上的示例1，在数据库test的表maxwell插入了一条数据，那么你在名为maxwell的topics会接收到一条消息，含有数据库、表、时间戳、更新类型等字段。
mysql> insert into `test`.`maxwell` set id = 1, daemon = 'Stanislaw Lem';
maxwell: {
"database": "test",
"table": "maxwell",
"type": "insert",
"ts": 1449786310,
"xid": 940752,
"commit": true,
"data": { "id":1, "daemon": "Stanislaw Lem" }
}
示例2,更新语句也是类似的。不同的是，更新的消息会多一个字段old，记录字段尚未被更新之前的数据。
mysql> update test.maxwell set daemon = 'firebus! firebus!' where id = 1;
maxwell: {
"database": "test",
"table": "maxwell",
"type": "update",
"ts": 1449786341,
"xid": 940786,
"commit": true,
"data": {"id":1, "daemon": "Firebus! Firebus!"},
"old": {"daemon": "Stanislaw Lem"}
}
生产者
MaxWell支持多种生产者，官网自带配置文档。以Kafka为例，默认会把消息发送到名为maxwell的topics，你也可以自定义配置。
踩坑
在MaxWell启动后，Kafka的生产者可以进行高性能的配置。如果添加以下的配置
kafka.acks = 1
kafka.compression.type = snappy
kafka.retries=0
消息会以snappy的方式进行压缩。什么是snappy压缩方式
在采用Composer包nmred/kafka-php消费消息时，遇到MaxWell生产的消息无法读取。
后来定位到是该Composer包不支持snappy压缩的消息，更换为php-rdkafka的扩展即可。
参考链接
打赏作者