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

Question

向Postgres连接器中添加新表的步骤应该是什么？我的连接器正在跟踪两个表（表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”添加到列表中，但它似乎没有触发此表的快照过程。

有什么想法吗？

Answer 1

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