Skip to content

Instantly share code, notes, and snippets.

@rjyala-godaddy
Created September 26, 2023 14:32
Show Gist options
  • Save rjyala-godaddy/36beb229564860722f485cae819b84f5 to your computer and use it in GitHub Desktop.
Save rjyala-godaddy/36beb229564860722f485cae819b84f5 to your computer and use it in GitHub Desktop.
Kafka Connect
SELECT slot_name,
pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn)) as replicationSlotLag,
pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn)) as confirmedLag,
active
FROM pg_replication_slots
getting the lag
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment