Debezium系列之：增加心跳检测heartbeat.interval.ms
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
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！