Topic: "streaming-data-pipelines"
infinyon/fluvio
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Language: Rust - Size: 34.4 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 4,937 - Forks: 517

quixio/quix-streams
Python Streaming DataFrames for Kafka
Language: Python - Size: 8.51 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 1,388 - Forks: 80

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

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: 12 months ago - Pushed at: about 1 year ago - Stars: 4 - Forks: 0

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