各位,
我试图了解cdc过程中的德比zium postgres源连接器,因为我怀疑数据丢失。这是我的场景,我有一个连接器名称 "deb-connector"
它通过复制槽从大约10个表中提取数据 "deb-1"
和插件 "wal2json"
,一切都很好。现在我想在同步中再添加两个表,所以我创建了一个名为 "deb-connector-updt"
再加上两张table,跳到同一个rep槽上 "deb-1"
. 快照最初(通常情况下)需要一段时间才能完成并运行。这是我的问题,
就快照过程而言,我的理解是,它将采取第二个连接器的新快照(请纠正我,如果我错了)。?
如果是这样的话,那么初始过程将是数据库中所有记录的读取事件,所有记录(2.5k rec)都应该飞到Kafka,不管发生什么,对吗?但我没有看到它们,相反,我只看到疾控中心的记录(23条记录)在流动。
只有当它不创建新快照并且基本上从停止的地方开始(只有当快照绑定到插槽时才有意义)时,才会发生这种情况(或者)每当我想从配置中添加/删除表列表时,我是否应该创建一个新的插槽(这根本没有意义)?
如果Maven们能回答这个问题,我将不胜感激!谢谢您!
暂无答案!
目前还没有任何答案,快来回答吧!