go-streams

The framework offers a clear, composable syntax for defining pipelines with sources, flows, and sinks, as highlighted in the README's overview, making complex transformations readable and maintainable.

Includes a wide range of flow operations like Map, Filter, SlidingWindow, and AdaptiveThrottler, enabling sophisticated data manipulation without external dependencies in the core module.

Supports integrations with Kafka, Redis, and cloud storage through separate modules, allowing real-world use cases without bloating the lightweight core, as detailed in the connectors section.

The AdaptiveThrottler adjusts processing rates based on CPU and memory usage, providing efficient resource management for dynamic workloads, a feature emphasized in the key features.