-------------------
- Some postgres instances do not have hstore available. do not make that assumption
- hstore rec must exist && must have an installed version to use hstore
- Send all stream schemas before syncing for binlog
- dsn string was causing encoding issues for a client with backslashes in their password
- Change bookmark property from primary key to replication key
- Only fetch the end_lsn if a log based stream is in play. aurora, for instances, does not support lsns
- Do NOT consume message if its lsn > the global end_lsn for that tap run
- Don't break logical replication just because we haven't seen a message in 10 seconds