demo of parsing postgres replication stream with rust based materialize's postgres utils and their replication code
A postgres instance with a testdb dfatabase and a testtbl table with a id and name column.
CREATE DATABASE testdb;
\c testdb;
CREATE TABLE testtbl (id int, name text);
CREATE PUBLICATION testpub FOR TABLE testtbl;
INSERT INTO testtbl VALUES (1, 'snot');
rust & cargo
Run with the postgres connection string as the first argument.
cargo run -- "host=127.0.0.1 port=5433 user=postgres password=password dbname=testdb"potentially the starting position can be provided by a 2nd parameter
cargo run -- "host=127.0.0.1 port=5433 user=postgres password=password dbname=testdb" 0/17773B0