我正在学习debezium连接器,并将debezium用于postgresql。我有一个小问题需要澄清。
想象一下这样的情况。我有一个名为tableA的表的debezium连接器,该表上发生的更改将发布到名为topicA的主题。连接器工作时没有任何问题,并且发布到主题的更改没有任何问题。现在想想,出于某种原因,我需要删除我的连接器,并为发布到同一主题的同一个表启动一个具有相同配置的新连接器。因此,在我停止连接器和启动具有相同配置的新连接器之间存在时间间隔。在那段时间里,我的表A上发生了什么变化。
这会从它停止的地方开始吗?或者会发生什么?
Dushan,答案取决于连接器如何停止。在这里阐述了各种场景
https://debezium.io/documentation/reference/stable/connectors/postgresql.html#postgresql-kafka连接过程优雅地停止
在理想的情况下,日志序列号记录在数据库历史主题中。除非历史主题被重新创建或消息过期,否则LSN偏移量将被存储,并且在重新启动时将从该位置恢复