如何在 AWS devezium 中设置 LSN 编号以在 LSN 后启动事件日志

Question

如何在 AWS devezium 中设置 LSN 编号以在 LSN 之后启动事件日志，就像我在表 Employee 中有 100 条记录，在备份后，我有这 100 条记录并恢复它，现在我使用 debezium 启动 cdc，并使用 AWS 启动 kafka MSk。 它应该开始从员工表中获取 101 的记录。

备份后我将获得 LSN 编号，但如何在 debezium 中配置它？

我获得了更改LSN和提交LSN的信息，但不确定这是否可以作为解决方案。

Answer 1

如果您知道第 100 条记录的 commit_lsn，请尝试使用以下函数。 pg_replication_slot_advance(slot_name,move_to_lsn);

将

move_to_lsn

设置为第 100 条记录的 commit_lsn。

这个函数基本上会将槽的confirmed_flush_lsn推进到指定位置。

请参阅下面的文档 https://pgpedia.info/p/pg_replication_slot_advance.html

CAUTION:-Before advancing the slot make sure that there are no other transactions in between current_confirmed_flush_lsn and commit_lsn of 100th record.Because after advancing you will loose them.