I’m interested in using the Postgres CDC source. I have a use case where row changes have a User ID, and I want: • records relating to user A to get synced to destination1, and • records relating to user B to get synced to destination2 I know that I can run a transformation after the load, but that’s too late. destination1 would see records for both user A and B. Is there a way to apply a filter beforehand?

No. Airbyte runs queries that select all data in your table

Ok I’ll look into AWS DMS / Debezium. Thanks!