Libraries & frameworks
go-streams
reugn/go-streams
A lightweight Go stream-processing library whose declarative DSL composes sources, flows and sinks into data pipelines, with built-in map, filter, windowing and throttling operators plus Kafka, Redis and WebSocket connectors.
Topics
Related projects
workflow14.4kSogou C++ Workflow is a lightweight, high-performance asynchronous networking and parallel computing framework. It provides HTTP, Redis, MySQL, and Kafka clients, DAG task orchestration, and service governance primitives.
faust1.9kFaust is a Python stream processing library that brings Kafka Streams ideas to Python, with asyncio-based event processing, distributed tables and durable state stores.
riko1.6kA pure-Python library for composing config-driven stream processing pipelines over RSS feeds, web content and structured data.
funboost894A Python distributed function-scheduling framework where a single @boost decorator adds message queues, concurrency, rate limiting, FaaS endpoints and a management UI to ordinary functions.
testcontainers-spring-boot875Spring Boot auto-configurations that spin up stateful services like Kafka, Postgres and Redis as Testcontainers during integration tests and expose their connection properties automatically.
components-contrib606A community-driven library of reusable building blocks for distributed apps, covering messaging, state, bindings, and secrets for Dapr.