如何将表添加到Debezium Postgres连接器



在Postgres连接器中添加新表的步骤应该是什么?我的连接器正在跟踪2个表(表1和表2(,我想添加另一个已经存在的表(表3(,该表在我的数据库中有数据。

这是我当前的配置:

{
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"database.dbname": "db_name",
"database.hostname": "HOST_URL",
"database.password": "$PASSWORD",
"database.port": "5432",
"database.server.name": "db_data",
"database.sslmode": "require",
"database.user": "user_replication",
"plugin.name": "pgoutput",
"publication.autocreate.mode": "disabled",
"table.include.list": "public.table1, public.table2"
},
"name": "db-to-kafka-source"

}

我试图修改连接器";table.include.list";并添加";public.table3";到列表中,但它似乎不会触发该表的快照进程。

有什么想法吗?

no快照不会被触发。这应该通过为1.6计划的特别快照来解决。同时,您可以启动一个临时连接器来执行新表的快照,然后恢复原始表。

相关内容

  • 没有找到相关文章

最新更新