You need to build CDC (Change Data Capture) from PostgreSQL. What do you prefer?
So‘rovnoma
- Debezium + Kafka — a popular standard with log support
- Apache NiFi — drag-and-drop stream from change logs
- LogMiner + Kafka Connect — if you work with Oracle and want unification
- Own agent based on logical replication + custom JSON format