1. 準備工作

1.1. MySQL賬號

根據Canal官方說明，需要申請一個MySQL資料庫的賬號，該賬號具有如下許可權

CREATE USER canal IDENTIFIED BY 'canal';  
-- 至少具有如下許可權
GRANT SELECT, SHOW VIEW, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';
-- GRANT ALL PRIVILEGES ON *.* TO 'canal'@'%' ; -- 需要具有SHOW VIEW 許可權
FLUSH PRIVILEGES;

並保證目標主機與MySQL資料庫之間3306

1.2. 安裝Java

由於是一個Java程式，因此需要在目標機上事先安裝JDK。

1.3. Kafka

本專案目的是將Binlog資料發往Kafka，因此需要一個Kafka叢集或單機節點，並保證9092埠的連通性。

1.4. Zookeeper

如果啟用高可用，或將元資料儲存在Zookeeper上，那麼需要保證目標主機與ZK叢集之間2181埠的連通性。

2. 配置工作

  配置Canal是一個不斷摸索的過程，根據Git上面的文件，以及專案原始碼，如果有問題出現，基本上可以定位到問題出處。雖然Git上面有比較詳盡的說明，但在測試時，還是會遇到各種各樣的問題。這就需要充分理解相關配置引數的含義，以及引數之間的搭配，才能更好地使用這個工具。

2.1. canal說明

需要特別注意以下幾個配置內容

## 配置ZK地址：如果需要啟用高可用，目前高可用僅支援同時一個節點工作
canal.zkServers=

## 配置sink方式：目前支援以下三種
### tcp, kafka, RocketMQ
canal.serverMode=

## 併發配置：這裡是二選一
### 1. 單執行緒處理
canal.instance.parser.parallel = false
### 2. 處理過程如下[原始碼]
###  * 1. 網路接收 (單執行緒)
###  * 2. 事件基本解析 (單執行緒，事件型別、DDL解析構造TableMeta、維護位點資訊)
 

###  * 3. 事件深度解析 (多執行緒, DML事件資料的完整解析)
###  * 4. 投遞到store (單執行緒)
canal.instance.parser.parallel = true
canal.instance.parser.parallelThreadSize = 6
canal.instance.parser.parallelBufferSize = 4096

## MQ配置：配置Kafka的伺服器: “IP1:9092,IP2:9092,,,”
canal.mq.servers=

## MQ配置：設定訊息序列化方式，true--json, false--protobuf
canal.mq.flatMessage=true

## MQ設定
canal.mq.acks=
canal.mq.lingerMs=

2.2. instance說明

Instance中需要注意的配置專案如下

## GTID設定：如果配置為true，那麼需要給出：canal.instance.master.gtid=
## 一般設定為false，小的專案就夠了：自動尋找，以及記憶Binlog位置
canal.instance.gtidon=false

## 設定源資料庫：使用者名稱、密碼、預設資料庫
canal.instance.dbUsername=
canal.instance.dbPassword=
canal.instance.defaultDatabaseName = 

## Kafka設定
canal.mq.topic=
## 二選一
## 1. 配置partition數量，並配合對映規則：實際程式碼中，優先判斷該種情況
canal.mq.partitionsNum=3
canal.mq.partitionHash=mytest.person:id,mytest.role:id
## 2. 配置為0，或不配置
canal.mq.partition=

3. 注意事項

3.1. 預設資料庫

在實際測試中，這個預設資料庫的設定不知道起到了什麼作用

canal.instance.defaultDatabaseName = 

在獲取MySQL Binlog時，這個MySQL例項的Binlog都獲取到了，並傳輸到了Kafka中。

3.2. 配置錯誤

在配置mq.yml檔案時，遇到了一個基本常識錯誤

## 錯誤配置
canalDestinations:
  - canalDestination: example
    topic:example
    partition:0

## 正確配置
canalDestinations:
  - canalDestination: example
    topic: example
    partition: 0

即在YML配置中，基本上是這種模式的[Key: value]。

  博主在使用的時候，場景比較簡單，配置也較為簡單，目標僅是讓整個流程跑起來，對於其他的引數未做詳細的瞭解以及探究，其中不免有錯誤之處，歡迎留言指正。