我是靠谱客的博主 落寞鸡翅,最近开发中收集的这篇文章主要介绍Debezium系列之:增加心跳检测一、需求背景二、心跳检测含义三、增加心跳检测参数四、查看心跳检测topic,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

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系列之:增加心跳检测一、需求背景二、心跳检测含义三、增加心跳检测参数四、查看心跳检测topic的全部内容,希望文章能够帮你解决Debezium系列之:增加心跳检测一、需求背景二、心跳检测含义三、增加心跳检测参数四、查看心跳检测topic所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(45)

评论列表共有 0 条评论

立即
投稿
返回
顶部