Maxwell官網http://maxwells-daemon.io/

1.下載解壓

cd /usr/local/
mkdir maxwell
cd maxwell
wget https://github.com/zendesk/maxwell/releases/download/v1.27.1/maxwell-1.27.1.tar.gz # 有點慢
tar zxvf maxwell-1.27.1.tar.gz

2.編輯配置檔案

mkdir /usr/local/maxwell/conf
cd /usr/local/maxwell/conf
cp ../maxwell-1.27.1/config.properties.example ./prod.maxwell.properties # prod.maxwell.properties是自定義的配置檔名稱
 
 
vim prod.maxwell.properties 
# 新增或修改以下內容
producer=kafka
kafka.bootstrap.servers=192.168.32.36:9092,192.168.32.37:9092,192.168.32.38:9092 # kafka地址
kafka_topic=prod.%{database}.%{table}


host=1.2.3.4 # mysql地址
user=mysqlUser # mysqlUser
password=mysqlPassword #mysqlPassword

#filter=exclude: *.*, include: databaseA.tableB, include: databaseC.tableD # 可選過濾 只留下databaseA.tableB和databaseC.tableD
 

http_port=9082 # 開啟http用於監控
metrics_type=http
metrics_jvm=true
metrics_prefix=metrics # 自定義指標字首 預設是MaxwellMetrics太長

3.編輯啟動指令碼

cd /usr/local/maxwell/
mkdir logs
vim prod.maxwell.sh
# 新增以下內容
baseDir=/usr/local/maxwell
${baseDir}/maxwell-1.27.1/bin/maxwell --config ${baseDir}/config/prod.maxwell.properties >> ${baseDir}/logs/prod.maxwell.log 2
 
>&1 &
# 給指令碼新增可執行許可權
chmod +x prod.maxwell.sh

4.如果需要指定Kafka副本數和分割槽數需要預先建立topic

5.啟動服務

./prod.maxwell.sh
cat logs/prod.maxwell.log
# 另外可通過 http://ServerIP:9082/healthcheck 可以檢視服務健康狀態 /metrics 以json返回當前執行資訊 /ping 返回 pong