#!/usr/bin/env bash

pg2kinesis \
  --pg-dbname ${PGDATABASE} \
  --pg-host ${PGHOST} \
  --pg-user ${PGUSER} \
  --pg-slot-name kinesis \
  --pg-slot-output-plugin wal2json \
  --stream-name ${KINESIS_STREAM_NAME} \
  --create-slot \
  --full-change