Skip to content

Repository files navigation

Source Collector Application for Kafka Streams to process it

Part of ETL (Extract-Transform-Load) pipeline

Debezium postgres connector will watch the bin/logs of our database and use Capture Data Change CDC mechanism to watch out for the CRUD operations and deliver them to Kafka Event processor pipeline for processing

Tech-stack: python, flask, debezium, Kafka & postgres

About

Source Collector Application for Kafka Streams to process the data and put them in sink here: google sheets

Topics

Resources

Stars

1 star

Watchers

1 watching

Forks

Releases

Packages

Used by

Contributors

Languages