1、解压 maxwell-1.25.0.tar.gz 到/opt/module 目录tar -zxvf
tar -zxvf /opt/software/maxwell-1.25.0.tar.gz -C /opt/module/2、在数据库中建立一个 maxwell 库用于存储 Maxwell 的元数据
mysql -uroot -p123456mysql> CREATE DATABASE maxwell ; 分配一个帐户可以操作数据库 mysql> GRANT ALL ON maxwell.* TO 'maxwell'@'%' IDENTIFIED BY '123456'; 该账户的分配可以监控其他数据库的权限 mysql> GRANT SELECT ,REPLICATION SLAVE , REPLICATION CLIENT ON *.* TO maxwell@'%';3、复制配置文件
cp config.properties.example config.properties4、修改config.properties
producer=kafka kafka.bootstrap.servers=hadoop202:9092,hadoop203:9092,hadoop204:9092 #需要添加 kafka_topic=gmall2020_db_m # mysql login info host=hadoop202 user=maxwell password=123456 #需要添加 将使用后续的初始化 client_id=maxwell_1
注：默认或输出到指定： Kafka 主题的一个 kafka 因为多个分区并行可能会被打乱binlog 的顺序
要提高平行度，首先设置 kafka 的分区数>1,然后设置 producer_partition_by 属性
可选值 producer_partition_by=database|table|primary_key|random| column
5、在/home/atguigu/bin 目录下编写 maxwell.sh 启动脚本
vim /home/user/bin/maxwell.sh /opt/module/maxwell-1.25.0/bin/maxwell --config /opt/module/maxwell-1.25.0/config.properties >/dev/null 2>&1 &6、授予执行权
sudo chmod x /home/user/bin/maxwell.sh7、操作启动程序
maxwell.sh