maxwell监听MySQL的Binlog

1、下载解压
http://maxwells-daemon.io/quickstart/

2、修改MySQL服务器配置

$ vi my.cnf

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

  

 

  
1
  
2
  
3
  
4
  
5
  
6
 

3、创建账号给maxwell使用

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


  

 

  
1
  
2
  
3
  
4
 

4、启动监听并输出到终端

bin/maxwell --user='maxwell' --password='123456' --host='127.0.0.1' --producer=stdout

  

 

  
1
 

也可以将配置写入配置文件

$ cat config.properties
log_level=info
producer=stdout
host=localhost
user=maxwell
password=123456


$ bin/maxwell --config config.properties

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
 

5、输出数据

mysql> insert into test.e set m = 4.2341, c = now(3), comment = 'I am a creature of light.';
{ "database":"test", "table":"e", "type":"insert", "ts":1477053217, "xid":23396, "commit":true, "position":"master.000006:800911", "server_id":23042, "thread_id":108, "data":{ "id":1, "m":4.2341, "c":"2016-10-21 05:33:37.523000", "comment":"I am a creature of light." }
}


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
 

文章来源: pengshiyu.blog.csdn.net，作者：彭世瑜，版权归原作者所有，如需转载，请联系作者。

原文链接：pengshiyu.blog.csdn.net/article/details/92068587