canal指定binlog位點啟動

1. canal基於集群模式搭建，所用版本為帶有視覺化頁面的canal-1.1.4，包結構如下

canal-adapter canal-admin

canal-server

2.抽取例項主要配置canal-server，包結構如下

cd canal-server/ binconf liblogs #conf目錄 [canal-server]$ cd conf/ canal_local.properties canal.properties example logback.xml metrics spring #spring目錄 [conf]$ cd spring/ base-instance.xml default-instance.xml file-instance.xml group-instance.xml memory-instance.xml

tsdb

3.集群模式下每乙個抽取例項所記錄的binlog位點資訊存在與zookeeper中，使用的配置檔案為default-instance.xml

a.canal.properties

canal.instance.global.spring.xml = classpath:spring/default-instance.xml

b.instance.properties 中binlog位點資訊配置如下

# position info canal.instance.master.address=127.0.0.1:3306 # binlog日誌檔名 canal.instance.master.journal.name= # binlog具體位點 canal.instance.master.position= # binlog指定時間戳

canal.instance.master.timestamp=

4.mysql中找到需要指定的日誌位點資訊

-- 1.檢視mysql binlog 日誌: show binary logs ; -- 2.檢視某一binlog具體位點資訊: show binlog events in 'mysql-bin.000001'; -- 3.檢視當前binlog最新位點:

show master status;

5.定位具體binlog位點有兩種方式

a.通過name和position確定

# binlog日誌檔名 canal.instance.master.journal.name= 'mysql-bin.000001' # binlog具體位點

canal.instance.master.position=100

b.通過時間戳指定

# binlog指定時間戳

canal.instance.master.timestamp=1611072000000

c.當使用以上方式指定位點啟動時需要刪除zookeeper中儲存的binlog位點資訊(如canal為本地模式則操作具體例項下的meta.dat檔案)

# 檢視位點資訊 example 為具體抽取例項的檔名 get /otter/canal/destinations/example/1001/cursor },"postion": }# 刪除位點資訊

delete /otter/canal/destinations/example/1001/cursor

d.如果指定name與position啟動，可以直接修改zookeeper中的位點資訊無需修改instance.properties

set /otter/canal/destinations/example/1001/cursor  
},"postion":
}

6.需要刪除zookeeper中儲存的binlog位點資訊(canal為本地模式則操作具體例項下的meta.dat檔案)是因為canal例項在啟動時先會查詢上一次成功儲存的位點資訊，如果存在則不會讀取instance.properties，當不存在時才會讀取instance.properties中相關的binlog位點資訊

canal指定binlog位點啟動

canal 從指定binlog日誌檔案及定位中讀取

通過BINLOG日誌查詢指定日期的SQL語句

位運算知識點

canal指定binlog位點啟動

canal 從指定binlog日誌檔案及定位中讀取

通過BINLOG日誌查詢指定日期的SQL語句

位運算 知識點

相關推薦

位運算知識點