Checking capturing data change use logical slot

debezium_checking_capture_data.sql

-- Create slot
SELECT pg_create_logical_replication_slot('test_slot_v1', 'pgoutput');

-- Show publication name
SELECT pubname FROM pg_publication_tables GROUP BY pubname;

-- Peak changes (does not consume changes)
SELECT pg_logical_slot_peek_binary_changes('test_slot_v1', NULL, NULL, 'publication_names', 'dbz_publication', 'proto_version', '1');

-- Get changes (consumes changes)
SELECT pg_logical_slot_get_binary_changes('test_slot_v1', NULL, NULL, 'publication_names', 'dbz_publication', 'proto_version', '1');

-- Drop slot
SELECT pg_drop_replication_slot ('test_slot_v1');