pgsqlbinlog功能点解析

//设置心跳时间，就算没有数据也会保持心跳

props.setProperty(heartbeat.interval.ms, 20000);

for(ChangeEvent<String, String> r : records) {

try{

if(log.isDebugEnabled()) {

log.debug({}\n{}, r.key(), r.value());

}

if(r.value() != null r.value().startsWith({ts_ms)) {

continue;

}

xxx 具体数据处理

} catch(Exception e) {

log.error(PGLog-binlog param:[{}], r, e);

}

　　心跳这个是当时上生产的时候，突然发现没有数据变更的时候，有报警，说delay了。。。这顿害怕

　　大概意思

　　数据库中有许多更新正在被跟踪，但只有极少数更新与连接器正在为其捕获更改的表和模式相关。这种情况可以通过周期性的心跳事件轻松解决。设置heartbeat.interval.ms连接器配置属性。

　　由于WAL由所有数据库共享，因此使用的WAL数量趋于增长，直到Debezium为其捕获更改的数据库触发事件。为了克服这一点，有必要:使用heartbeat.interval.ms连接器配置属性启用周期性心跳记录生成。定期从Debezium正在捕捉变化的数据库中发出更改事件。

　　其中

云计算