We're using the following config. The DB is on RDS and the schema we're whitelisting has a single table we're capturing. { "name": "{{connector_name}}", "config": { "column.blacklist": "thumbnail_service.thumbnail.asset_type,thumbnail_service.thumbnail.score", "connector.class": "io.debezium.connector.postgresql.PostgresConnector", "database.hostname": "{{db_host}}", "database.port": "{{db_port}}", "database.user": "{{db_user}}", "database.password": "{{db_pass}}", "database.dbname": "thumbnail", "database.server.name": "thumbnail", "max.batch.size": "{{max_batch_size}}", "max.queue.size": "{{max_queue_size}}", "plugin.name": "wal2json_rds", "schema.whitelist":"thumbnail_service", "tasks.max": "1", "transforms": "unwrap,ReplaceField", "transforms.unwrap.type": "io.debezium.transforms.UnwrapFromEnvelope", "transforms.unwrap.drop.tombstones": "false", "transforms.ReplaceField.type": "org.apache.kafka.connect.transforms.ReplaceField$Key", "transforms.ReplaceField.renames": "asset_id:media_id,created_date:created,updated_date:last_modified,timestamp:video_offset_timestamp" } }