需要了解debezium postgres源连接器的cdc流

lg40wkob  于 2021-07-15  发布在  Kafka
关注(0)|答案(0)|浏览(275)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题