streaming-data-pipelines
There are 6 repositories under streaming-data-pipelines topic.
infinyon/fluvio
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
quixio/quix-streams
Python stream processing for Kafka
swimos/swim-rust
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
confluentinc/demo-change-data-capture
This demo shows how to capture data changes from relational databases (Oracle and PostgreSQL) and stream them to Confluent Cloud, use ksqlDB for real-time stream processing, send enriched data to cloud data warehouses (Snowflake and Amazon Redshift).
confluentinc/demo-database-modernization
This demo shows how to stream data to cloud databases with Confluent. It includes fully-managed connectors (Oracle CDC, RabbitMQ, MongoDB Atlas), ksqlDB/Flink SQL as stream processing engine.
confluentinc/demo-realtime-data-warehousing
Streaming data pipelines for real-time data warehousing. Includes fully managed connectors (PostgreSQL CDC, Snowflake).