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

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

一、需求背景

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

二、心跳檢測含義

heartbeat.interval.ms：

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

三、增加心跳檢測參數

debezium connector中增加參數：

• “heartbeat.interval.ms”: 10000

四、查看心跳檢測topic

心跳檢測topic如下所示：

• __debezium-heartbeat.debezium-prod-dd_ods_nitp_prod_1h

總結

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

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