BenthosFancy stream processing made operationally mundane
Stars: ✭ 3,705 (+18425%)
xlstreamTurns XLSX into a readable stream.
Stars: ✭ 148 (+640%)
LograngeHigh performance data aggregating storage
Stars: ✭ 181 (+805%)
DolphinbeatA server that pulls and parses MySQL binlog, pushs change data into different sinks like Kafka.
Stars: ✭ 164 (+720%)
Incubator StreampipesApache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Stars: ✭ 209 (+945%)
ReDeA Redis dehydrator module
Stars: ✭ 63 (+215%)
VectorsqlVectorSQL is a free analytics DBMS for IoT & Big Data, compatible with ClickHouse.
Stars: ✭ 171 (+755%)
tipsTiKV based Pub/Sub server
Stars: ✭ 31 (+55%)
coronamqThe simplest way to implement a task queue with Java, Vertx and PostgreSQL.
Stars: ✭ 23 (+15%)
MediapipeCross-platform, customizable ML solutions for live and streaming media.
Stars: ✭ 15,338 (+76590%)
SamsaraSamsara is a real-time analytics platform
Stars: ✭ 132 (+560%)
CoreBuild platforms that flexibly mix SQL, batch, and stream processing paradigms
Stars: ✭ 231 (+1055%)
haraqaHigh Availability Routing and Queueing Application
Stars: ✭ 50 (+150%)
Flink Sql CookbookThe Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.
Stars: ✭ 189 (+845%)
beepbeep-3An event stream processor anyone can use
Stars: ✭ 20 (+0%)
Ferolight, fast, scalable, streaming microservices made easy
Stars: ✭ 175 (+775%)
vectorA high-performance observability data pipeline.
Stars: ✭ 12,138 (+60590%)
Bats面向 OLTP、OLAP、批处理、流处理场景的大一统 SQL 引擎
Stars: ✭ 152 (+660%)
SPSC QueueA highly optimized single producer single consumer message queue C++ template
Stars: ✭ 185 (+825%)
Awesome Streaminga curated list of awesome streaming frameworks, applications, etc
Stars: ✭ 1,879 (+9295%)
spStream Processors on Kafka in Golang
Stars: ✭ 29 (+45%)
DparkPython clone of Spark, a MapReduce alike framework in Python
Stars: ✭ 2,668 (+13240%)
Neo4j StreamsNeo4j Kafka Integrations, Docs =>
Stars: ✭ 126 (+530%)
RikoA Python stream processing engine modeled after Yahoo! Pipes
Stars: ✭ 1,571 (+7755%)
Fluent BitFast and Lightweight Logs and Metrics processor for Linux, BSD, OSX and Windows
Stars: ✭ 3,223 (+16015%)
fs[READ-ONLY] Enterprise queue solutions for PHP. Filesystem transport.
Stars: ✭ 32 (+60%)
PipelinedbHigh-performance time-series aggregation for PostgreSQL
Stars: ✭ 2,447 (+12135%)
streamsx.kafkaRepository for integration with Apache Kafka
Stars: ✭ 13 (-35%)
PluckPluck text in a fast and intuitive way 🐓
Stars: ✭ 202 (+910%)
Media Stream Library JsJavaScript library to handle media streams on the command line (Node.js) and in the browser.
Stars: ✭ 192 (+860%)
distogramA library to compute histograms on distributed environments, on streaming data
Stars: ✭ 19 (-5%)
HstreamThe streaming database built for IoT data storage and real-time processing in the 5G Era
Stars: ✭ 166 (+730%)
coreSimple JSON-based messaging queue for inter service communication
Stars: ✭ 28 (+40%)
football-eventsEvent-Driven microservices with Kafka Streams
Stars: ✭ 57 (+185%)
Log Anomaly DetectorLog Anomaly Detection - Machine learning to detect abnormal events logs
Stars: ✭ 169 (+745%)
irisLightweight Component Model and Messaging Framework based on ØMQ
Stars: ✭ 50 (+150%)
Gojayfastest JSON encoder/decoder with powerful stream API for Golang
Stars: ✭ 2,009 (+9945%)
wmqWrapped message queue which based on rabbitmq,support http protocol
Stars: ✭ 27 (+35%)
RedisgearsDynamic execution framework for your Redis data
Stars: ✭ 152 (+660%)
microqMicro job queue built on mongo
Stars: ✭ 67 (+235%)
HudiUpserts, Deletes And Incremental Processing on Big Data.
Stars: ✭ 2,586 (+12830%)
aopAMQP on Pulsar protocol handler
Stars: ✭ 93 (+365%)
frizzleThe magic message bus
Stars: ✭ 14 (-30%)
WayebWayeb is a Complex Event Processing and Forecasting (CEP/F) engine written in Scala.
Stars: ✭ 138 (+590%)
daggerDagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
Stars: ✭ 238 (+1090%)
PsiPlatform for Situated Intelligence
Stars: ✭ 249 (+1145%)
Pulsar FlinkElastic data processing with Apache Pulsar and Apache Flink
Stars: ✭ 126 (+530%)
psychiqBackground job processing for Common Lisp
Stars: ✭ 45 (+125%)
WallyDistributed Stream Processing
Stars: ✭ 1,461 (+7205%)
AmadeusHarmonious distributed data analysis in Rust.
Stars: ✭ 240 (+1100%)
openPDCOpen Source Phasor Data Concentrator
Stars: ✭ 109 (+445%)
Elkeid-HUBElkeid HUB is a rule/event processing engine maintained by the Elkeid Team that supports streaming/offline (not yet supported by the community edition) data processing. The original intention is to solve complex data/event processing and external system linkage requirements through standardized rules.
Stars: ✭ 62 (+210%)