demo of parsing postgres replication stream with rust based materialize's postgres utils and their replication code

Requirements

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

Usage

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