Stream Processing
Showing 36 of 200 projects
A Clojure/ClojureScript library for building and using finite-state automata through functional composition.
A CLI tool for processing JSON and text data with functional pipelines using Ramda, supporting both command-line and interactive browser modes.
A lightweight JavaScript library to get image dimensions (width, height, type) from streams or data with minimal reads.
A Scala-based event data simulator that generates realistic web traffic for a fake music streaming service.
A .NET stream processing library for Apache Kafka, providing a Kafka Streams-like API for building real-time applications.
A .NET stream processing library for Apache Kafka, providing a Kafka Streams-like API for building real-time applications.
A stream-like, immutable, lazy-loading Go library for functional operations on slices with a focus on performance.
A TypeScript framework for building type-safe cloud applications with the AWS CDK, unifying infrastructure and runtime code.
RFC 4180 compliant, composable CSV parsing and encoding library for Elixir.
A clean and powerful Haskell stream processing library for building and connecting reusable streaming components.
A tiny functional language for querying and manipulating JSON, like sed but for JSON data.
A Redis client for Deno, supporting commands, pub/sub, streams, clustering, and advanced features like pipelining and client-side caching.
A Go library for creating/extracting archives, compressing/decompressing files, and walking virtual file systems across many formats.
A Blazor library for creating read-only file streams from file inputs and drag-and-drop targets with fine-grained control over memory usage.
A Clojure framework for building stateless stream processing applications on Kafka with built-in retry mechanisms.
Sample AWS Lambda functions for streaming data from S3 and Kinesis into Amazon Elasticsearch Service.
A real-time online machine learning library built on Apache Storm for scalable stream processing with incremental algorithms.
A Python interface to the Amazon Kinesis Client Library for building distributed applications that process streaming data reliably at scale.
A unified platform for big data stream and batch processing on Hadoop YARN with enterprise-grade operability.
A Node.js utility to read stdin as a string or Uint8Array with TTY handling.
A ZeroMQ-based enterprise messaging broker implementing all major messaging patterns in a single service.
A Java library for building data pipelines that connect Amazon Kinesis streams to AWS and non-AWS services like DynamoDB, Redshift, S3, and Elasticsearch.
A simple Node.js transform stream for reading text streams line-by-line with Unicode support.
A Gulp plugin that filters files in a vinyl stream using glob patterns, with optional restoration.
A Node.js interface to the Amazon Kinesis Client Library for building distributed applications that process streaming data at scale.
A distributed, scalable database built for stream processing applications on Apache Kafka using SQL syntax.
A .NET library for high-performance push-based stream processing, now part of System.IO.Pipelines.
An open-source real-time stream processing framework combining high-throughput event processing with low-latency SQL-like streaming queries.
A flexible anomaly detection framework for Kapacitor using fingerprinting algorithms and lossy counting.
A Gulp plugin for creating ZIP archives from files in your build pipeline.
A collection of utilities, operators, and serialization helpers for RxJava 1 to simplify reactive programming tasks.
Confluent's official .NET client for Apache Kafka, built on librdkafka for high performance and reliability.
A stream processing tool with a web interface for building and monitoring Apache Storm workflows using drag-and-drop components.
A Python toolkit for developing, testing, and managing Apache Storm streaming data processing topologies.
A Go library for packing and unpacking binary data streams with support for multiple data types and endianness.
A lightweight stream processing engine designed specifically for IoT data processing and analytics.
Related Tags
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.