Debezium系列之：增加心跳檢測heartbeat.interval.ms

• 一、需求背景
• 二、心跳檢測含義
• 三、增加心跳檢測參數
• 四、查看心跳檢測topic
• 五、修改心跳檢測topic前綴

一、需求背景

• 為每個debezium connector增加心跳檢測，更頻繁地將當前偏移量存儲在 kafka 中，從而在debezium connector重啟的情況下，能夠減少減少連接器重新啟動時需要重新發送的更改事件的數量。

二、心跳檢測含義

heartbeat.interval.ms：

• 心跳消息對于監視連接器是否正在從數據庫接收更改事件很有用。心跳消息可能有助于減少連接器重新啟動時需要重新發送的更改事件的數量。
• 要發送心跳消息，請將此屬性設置為正整數，表示心跳消息之間的毫秒數。
• 這個參數一般設置在1到10秒之間

三、增加心跳檢測參數

debezium connector中增加參數：

• “heartbeat.interval.ms”: 10000

四、查看心跳檢測topic

心跳檢測topic如下所示：

• __debezium-heartbeat.debezium-prod-dd_ods_nitp_prod_1h

總結

以上是生活随笔為你收集整理的Debezium系列之：增加心跳检测heartbeat.interval.ms的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。