How to add table to Debezium Postgres connector

user_577652 0
Viewed 712

What should be the steps for adding a new table into a Postgres connector? my connector is tracking 2 tables (table1 and table2) and I want to add anther table (table3) that already exists and have data in my DB.

This is my current config:

{
"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"

}

I have tried to modify the connector "table.include.list" and add "public.table3" to the list, but it doesn't seems to trigger the snapshot process for this table.

Any ideas?

debezium apache-kafka-connect postgresql
1 Answers

no the snapshot will not be triggered. This should be solved with ad-hoc snapshots planned for 1.6. In the meantime you can fire up a temprorary connector just to execut the snapshot of the new table and then resume the original one.

user_85725860
Related