Listen to Postgres changes and publish them over various channels (Kafka, HTTP endpoint). This repo is WIP early PoC.

• Complete HTTP hook implementation including connection reuse/pooling
• Introduce a scripting engine
• Work on backpressure system to make sure slow upstream won't cause memory issues to server
• Introduce Kafka support

I am starting off with Postgres (but will expand), and I want to introduce a fully scriptable engine rather than a limited versions of transformers (like in debezium), and with popular sinks it can be used in combination with benthos to compose a more complex systems.