1 Repo
Definitions of source and sink connections that can be created once and shared across multiple streaming queries.
Distinct from Data Source Connectivity Tools: Distinct from Data Source Connectivity Tools: focuses on reusable connection definitions for streaming pipelines, not general database connectivity.
Explore 1 awesome GitHub repository matching data & databases · Reusable Stream Connections. Refine with filters or upvote what's useful.
Arroyo is a high-performance stream processing platform built in Rust. It executes continuous SQL queries on streaming data with event-time semantics, enabling accurate windowed aggregations, joins, and stateful computations on unbounded event streams. The platform uses native Rust execution for high throughput and low latency, with periodic checkpointing for exactly-once fault tolerance and horizontal scaling across distributed workers. The system integrates deeply with Kafka for reading and writing topics with exactly-once delivery and supports change data capture (CDC) from MySQL and Postg
Arroyo creates reusable source and sink definitions through the Web UI or SQL that can be shared across queries.