CDC Replication

Implement change-data-capture replication from Postgres to a downstream store using logical replication or Debezium-style events. Include a consumer that applies changes idempotently and produces metrics on lag.