Kafka安装
- 解压kafka安装包 tar -xvzf kafka_2.12-2.1.1.tg
- 将start.sh 复制到kafka文件夹
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeperout.file 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafkaout.file 2>&1 &
#新建maxwell的topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic maxwell
Maxwell安装
- 在mysql中启用binglog打开my.cnf (vi /etc/my.cnf),添加：
[mysqld]
server_id=1
log-bin=master
binlog_format=row
- 解压maxwell安装包 tar –xvzf maxwell.tar.gz
- 复制check.sh 、filter.js、config.properties进maxwell文件夹(修改config.properties中得参数，host为mysql地址，user和password为mysql的用户名和密码，kafka.bootstrap.servers为kafka的地址，include中为需要同步的表名称)。
4.运行
nohup bin/maxwell --config config.properties > maxwellout.file 2>&1
