Stream Processing
Showing 36 of 200 projects
A one-stop, full-scenario integration framework for massive data, supporting data ingestion, synchronization, and subscription.
A fast, resilient distributed stream processing framework that simplifies real-time data applications with high performance and easy scaling.
A platform for building realtime, cost-effective, operations-focused applications.
A pure Rust client library for Apache Kafka with consumer, producer, and client APIs.
A Reactive Streams connector for Apache Kafka built on Akka Streams, enabling back-pressured integration for Java and Scala.
Run webpack as a stream to integrate with gulp for seamless asset bundling.
A memory-efficient PHP stream parser for large JSON files and streams, enabling iteration without loading entire documents.
A graphical toolkit for exploring, analyzing, and modifying real-time data streams through a visual interface.
A collection of pre-built Google Cloud Dataflow templates for common data import/export, backup, and bulk API operations.
A high-performance Rust stream processing engine with integrated AI capabilities for real-time data processing and intelligent analysis.
An open-source, in-memory, distributed batch and stream processing engine for Java applications.
A Clojure library providing deferreds and streams for asynchronous programming and interoperability between event-driven abstractions.
A Model Context Protocol server that enables AI assistants to interact with MongoDB databases and Atlas clusters.
An improved HyperLogLog implementation with LogLog-Beta bias correction, sparse representation, and flexible precision for cardinality estimation.
A distributed, in-memory optimized analytics database that fuses Apache Spark and Apache Geode for unified stream, transaction, and analytic workloads.
A high-performance C/C++ client library for Apache Kafka, supporting producers, consumers, and admin operations.
A saner Elixir library for launching and communicating with external OS processes, built on Erlang ports.
A Node.js convenience wrapper for crypto hashing with simpler API, better defaults, and support for buffers, strings, streams, and files.
A scalable n:m message multiplexer written in Go for routing messages from multiple sources to multiple destinations.
A Java/.NET component for complex event processing (CEP), streaming SQL, and event series analysis.
A centralized platform for security monitoring and analysis, integrating big data technologies for log aggregation, threat detection, and behavioral analytics.
A header-only C++14 library providing push-based pipelines for expressive collection processing with operators like filter, transform, and fork.
A Lua Kafka client driver for OpenResty/ngx_lua using the cosocket API for non-blocking communication.
A Gulp plugin for concatenating files in a streaming pipeline with flexible configuration options.
A lightweight real-time big data streaming engine built on Akka for high-throughput, low-latency data processing.
Interactive grep tool for real-time filtering of streaming data with archived mode for static files.
A data pipeline engine for security teams to collect, transform, enrich, and route telemetry data at scale.
A Gulp plugin that filters streams to only pass through files changed since the last run.
A low-code visual tool for domain experts to build, run, and monitor real-time decision algorithms on streaming data.
A self-service IoT toolbox enabling non-technical users to connect, analyze, and explore industrial IoT data streams.
An open-source, cloud-native streaming database designed for real-time data processing and IoT applications.
A Gulp plugin for flexible file renaming during build pipelines.
A Java client library for building scalable, fault-tolerant applications that consume and process data from Amazon Kinesis Data Streams.
A ternary gulp plugin that conditionally controls the flow of vinyl objects in your build pipeline.
A collection of interactive RxJS puzzles to practice Observable manipulation through real-world UI challenges.
A Go library for decoding/encoding XML to/from map[string]interface{} (or JSON) and extracting values with dot-notation paths.
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.