decoderbufs

pig repo add pgdg -u    # add pgdg repo and update cache

pig install decoderbufs;		# install via package name, for the active PG version

pig install decoderbufs -v 18;   # install for PG 18
pig install decoderbufs -v 17;   # install for PG 17
pig install decoderbufs -v 16;   # install for PG 16
pig install decoderbufs -v 15;   # install for PG 15
pig install decoderbufs -v 14;   # install for PG 14

shared_preload_libraries = 'decoderbufs';

shared_preload_libraries = 'decoderbufs'
wal_level = logical
max_wal_senders = 8
max_replication_slots = 4

-- Create a logical replication slot
SELECT * FROM pg_create_logical_replication_slot('decoderbufs_demo', 'decoderbufs');

-- Perform table modifications
INSERT INTO my_table VALUES (1, 'test');
UPDATE my_table SET col = 'updated' WHERE id = 1;

-- Peek at changes in debug text mode
SELECT data FROM pg_logical_slot_peek_changes(
    'decoderbufs_demo', NULL, NULL, 'debug-mode', '1');

-- Consume changes
SELECT data FROM pg_logical_slot_get_changes(
    'decoderbufs_demo', NULL, NULL, 'debug-mode', '1');

-- Check slot status
SELECT * FROM pg_replication_slots WHERE slot_type = 'logical';