GitHub topics: streaming-data-pipelines
quixio/quix-streams
Python Streaming DataFrames for Kafka
Language: Python - Size: 8.4 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 1,358 - Forks: 76

infinyon/fluvio
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Language: Rust - Size: 34.2 MB - Last synced at: 6 days ago - Pushed at: 7 days ago - Stars: 4,613 - Forks: 511

fgrzl/streams
A basic streaming data store
Language: Go - Size: 173 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 0 - Forks: 0

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.
Language: HCL - Size: 10.3 MB - Last synced at: 10 months ago - Pushed at: 11 months ago - Stars: 4 - Forks: 0

confluentinc/demo-realtime-data-warehousing
Streaming data pipelines for real-time data warehousing. Includes fully managed connectors (PostgreSQL CDC, Snowflake).
Language: HCL - Size: 10.7 MB - Last synced at: 10 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

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).
Language: HCL - Size: 8.57 MB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 10 - Forks: 2
