GitHub topics: streaming-data-pipelines
quixio/quix-streams
Python Streaming DataFrames for Kafka
Language: Python - Size: 8.83 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 1,399 - Forks: 83

infinyon/fluvio
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Language: Rust - Size: 34.6 MB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 4,949 - Forks: 515

graphform/swim-rust
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
Language: Rust - Size: 25.1 MB - Last synced at: 24 days ago - Pushed at: 26 days ago - Stars: 341 - Forks: 12

fgrzl/streams
A basic streaming data store
Language: Go - Size: 243 KB - Last synced at: about 1 month ago - Pushed at: about 1 month 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: about 1 year ago - Pushed at: about 1 year 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: about 1 year ago - Pushed at: about 1 year 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: about 1 year ago - Pushed at: about 1 year ago - Stars: 10 - Forks: 2
