一、Zookeeper
1.1、下載zk
wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz tar -zxvf zookeeper-3.4.10.tar.gz
1.2、制定配置文件
cd zookeeper-3.4.10/conf cp zoo_sample.cfg zoo.cfg
1.3、啟動zk
./zkServer.sh start
二、Kafka
2.1、下載Kafka
wget http://mirror.bit.edu.cn/apache/kafka/2.1.0/kafka_2.12-2.1.0.tgz tar -zxvf kafka_2
2.2、啟動Kafka
bin/kafka-server-start.sh config/server.properties
2.3、制定Kafka內存、並且啟動Kafka
2.4、創建一個為“maxwell“的topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic maxwell
三、Maxwell組件
3.1、下載maxwell組件
wget https://github.com/zendesk/maxwell/releases/download/v1.10.7/maxwell-1.10.7.tar.gz tar -zxvf maxwell-1.10.7.tar.gz
四、更新數據庫權限
4.1、給數據庫新增用戶名/密碼均為maxwell的權限
GRANT ALL on maxwell.* to'maxwell'@'%' identified by 'maxwell'; GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE on *.* to 'maxwell'@'%'; flush privileges;
4.2、啟動maxwell
bin/maxwell --user='maxwell' --password='maxwell' --host='127.0.0.1'
五、實踐
修改表中的數據
然後看到maxwell的日誌