我们的业务数据存放在mysql中，但是在大数据系统中我们需要拿hbase的数据进行业务处理，比如推荐系统。那么怎么可以将mysql中的业务数据实时同步到hbase中，从而可以在大数据系统中进行实时流式计算。本次推荐工具maxwell，方式是：我们打开mysql的binlog模式，数据以row为单位输出，然后通过maxwell发送给kafka，再由另一个程序将kafka数据录入到hbase中。

（1）mysql中配置binlog，开启后通过"show variables like 'log_bin';"查看是否ON的状态

（2）mysql中配置binlog的输出格式为row，开启后通过"show variables like 'binlog_format';"查看

（3）mysql开启log_slave_updates，该参数控制是否把所有的操作写入到binlog中，开启后通过"show variables like 'log_slave_updates';"查看

    将maxwell工具下载到linux机器上，主要是配置config.properties文件，重要的配置参考如下:

log_level=info

host=

user=

password=

port=

jdbc_options=autoReconnect=true

schema_database=  // 用于在mysql中新建一个binlog相关的数据库实例

producer=kafka

kafka.bootstrap.servers=

kafka_topic=

kafka.compression.type=snappy

kafka.retries=1

kafka.acks=1

kinesis_stream=maxwell

include_dbs=  // 需要处理的数据库实例

include_tables= // 需要处理的表格，用逗号分隔

kafka_version=0.9.0.1

client_id= // 标识符，可以包含英文

replica_server_id= // 只能是数字

nohup  bin/maxwell --config config.properties --log_level DEBUG &

如果maxwell实时同步成功，log中会有数据展示如下: