# 1. 安裝Maxwell ## 1. 下載安裝包 1）地址：https://github.com/zendesk/maxwell/releases/download/v1.29.2/maxwell-1.29.2.tar.gz **注：Maxwell-1.30.0及以上版本不再支持JDK1.8。** 2）將安裝包上傳到node1節點的/opt/software目錄 **注：此處使用教學版安裝包，教學版對原版進行了改造，增加了自定義Maxwell輸出數據中ts時間戳的參數，生產環境請使用原版。** ## 2. 將安裝包解壓至/opt/module ``` tar -zxvf maxwell-1.29.2.tar.gz -C /opt/module/ ``` ## 3. 修改名稱 ``` mv maxwell-1.29.2/ maxwell ``` # 2. 配置MySQL ## 1. 啟用MySQL Binlog 1）修改MySQL配置文件/etc/my.cnf ``` vim /etc/my.cnf ``` 2）增加如下配置 ``` [mysqld] #數據庫id server-id = 1 #啟動binlog，該參數的值會作為binlog的文件名 log-bin=mysql-bin #binlog類型，maxwell要求為row類型 binlog_format=row #啟用binlog的數據庫，需根據實際情況作出修改 binlog-do-db=gmall ``` **Maxwell要求Binlog采用Row-based模式。** 3）重啟MySQL服務 ``` systemctl restart mysqld ``` ## 2. 創建Maxwell所需數據庫和用戶 Maxwell需要在MySQL中存儲其運行過程中的所需的一些數據，包括binlog同步的斷點位置（Maxwell支持斷點續傳）等等，故需要在MySQL為Maxwell創建數據庫及用戶。 1）創建數據庫 ``` CREATE DATABASE maxwell; ``` 2）調整MySQL數據庫密碼級別 ``` set global validate_password_policy=0; set global validate_password_length=4; ``` 3）創建Maxwell用戶并賦予其必要權限 ``` CREATE USER 'maxwell'@'%' IDENTIFIED BY 'maxwell'; GRANT ALL ON maxwell.* TO 'maxwell'@'%'; GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE ON *.* TO 'maxwell'@'%'; ``` ## 3. 配置Maxwell 1）修改Maxwell配置文件名稱 ``` cd /opt/module/maxwell cp config.properties.example config.properties ``` 2）修改Maxwell配置文件 ``` vim config.properties #Maxwell數據發送目的地，可選配置有stdout|file|kafka|kinesis|pubsub|sqs|rabbitmq|redis producer=kafka #目標Kafka集群地址 kafka.bootstrap.servers=node1:9092,node2:9092 #目標Kafka topic，可靜態配置，例如:maxwell，也可動態配置，例如：%{database}_%{table} kafka_topic=maxwell #MySQL相關配置 host=node1 user=maxwell password=maxwell jdbc_options=useSSL=false&serverTimezone=Asia/Shanghai ```