上面幾篇文章講了基礎(chǔ)搭建過程:

canal搭建：http://www.itdecent.cn/p/917795a7acc1

zookeeper 搭建:http://www.itdecent.cn/p/d3c1727ba1c4

kafka搭建:http://www.itdecent.cn/p/c6916c4e4cae

下面我們來看如何串聯(lián)整體流程。

1.首先進(jìn)行canal配置。改動(dòng)配置文件canal.properties。改動(dòng)如下:

serverMode改為kafka

消息隊(duì)列配置:

監(jiān)聽地址改為本機(jī)地址

2.具體實(shí)例改動(dòng):

instance.propties改動(dòng):

topic配置說明:

在這里我們是topic:scheme.table配置。

kafka分片配置是根據(jù)表的主鍵進(jìn)行配置：

3.在這里有個(gè)關(guān)鍵步驟，需要開啟消息隊(duì)列的自動(dòng)創(chuàng)建topic模式。否則會(huì)報(bào)錯(cuò)

相關(guān)配置在kafka的server.properties

添加如下配置：

4.相關(guān)改動(dòng)完成后重啟canal和kafka

5.如何測(cè)試kafka接收binlog消息：

下載canal項(xiàng)目:git clone?https://github.com/alibaba/canal.git

運(yùn)行如下代碼：

項(xiàng)目代碼:

canal/example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientExample.java

改動(dòng)對(duì)應(yīng)配置為測(cè)試環(huán)境配置:

運(yùn)行CanalKafkaClientExample的main方法。然后改動(dòng)數(shù)據(jù)庫數(shù)據(jù)。查看效果，目前已經(jīng)成功接收數(shù)據(jù)