实时MySQL数据源同步中间件-Maxwell

curl -sLo - https://github.com/zendesk/maxwell/releases/download/v1.20.0/maxwell-1.20.0.tar.gz \
       | tar zxvf -
cd maxwell-1.20.0

docker pull zendesk/maxwell

brew install maxwell

vim /etc/mysql/my.cnf

[mysqld]
server_id=1
log-bin=master
binlog_format=row

mysql> CREATE USER 'maxwell'@'%' IDENTIFIED BY 'maxwell';
mysql> CREATE DATABASE maxwell;
mysql> GRANT ALL ON maxwell.* TO 'maxwell'@'%';
mysql> GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE ON *.* TO 'maxwell'@'%';
mysql> flush privileges;

maxwell --user='maxwell' --password='maxwell' --host='127.0.0.1' --producer=stdout

create database test;
use test;
create table maxwell(id int,daemon varchar(100));
insert into `test`.`maxwell` set id = 1, daemon = 'Stanislaw Lem';
update test.maxwell set daemon = 'firebus!  firebus!' where id = 1;

{
	"database": "test",
	"table": "maxwell",
	"type": "insert",
	"ts": 1551862585,
	"xid": 381,
	"commit": true,
	"data": {
		"id": 1,
		"daemon": "Stanislaw Lem"
	}
}

{
	"database": "test",
	"table": "maxwell",
	"type": "update",
	"ts": 1551862800,
	"xid": 450,
	"commit": true,
	"data": {
		"id": 1,
		"daemon": "firebus!  firebus!"
	},
	"old": {
		"daemon": "Stanislaw Lem"
	}
}

zkServer.sh start

kafka-server-start.sh /opt/kafka/config/server-1.properties 

maxwell --user='maxwell' --password='maxwell' --host='127.0.0.1' --producer=kafka --kafka.bootstrap.servers=localhost:9092 --kafka_topic=maxwell  

kafka-console-consumer.sh  --bootstrap-server localhost:9092 --topic maxwell

insert into `test`.`maxwell` set id = 1, daemon = 'Stanislaw Lem';
update test.maxwell set daemon = 'firebus!  firebus!!' where id = 1;