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

Question

将新表添加到 Postgres 连接器的步骤应该是什么？我的连接器正在跟踪 2 个表（table1 和 table2），我想添加已经存在并在我的数据库中有数据的另一个表（table3）。

这是我当前的配置：

{
"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”添加到列表中，但似乎没有触发该表的快照过程。

有什么想法吗？

Answer 1

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