201.hivemq / hivemq-community-edition
HiveMQ CE is a Java-based open source MQTT broker that fully supports MQTT 3.x and MQTT 5. It is the foundation of the HiveMQ Enterprise Connectivity and Messaging Platform
+23 stars
from 1,190 · score 3.18
Trending repositories
Ranked by Attention Score: stars gained over the last 180 complete days
201–300 of 381 by Attention Score · May 8, 2026 – Nov 3, 2026 (UTC)
202.TouK / nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
- flink
- flink-kafka
- apache-flink
- gui
- touk
- real-time
- +13 more
+23 stars
from 722 · score 3.18
203.aregtech / areg-sdk
Distributed C++ services from embedded to enterprise
+23 stars
from 345 · score 3.18
204.nebulastream / nebulastream
Data management for the sensor-edge-cloud continuum
- bigdata
- streamprocessing
+23 stars
from 80 · score 3.18
205.laminardb / laminardb
Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries, temporal stream joins, tumbling/session windows, and CDC/Kafka connectors. Lightweight, embeddable, and sub-microsecond latency
+23 stars
from 28 · score 3.18
206.datafold / data-diffArchived
Compare tables within or across databases
- database
- mysql
- postgresql
- snowflake
- rdbms
- trino
- +14 more
+22 stars
from 2,966 · score 3.14
207.reugn / go-streams
A lightweight stream processing library for Go
- stream-processing
- pipeline
- etl
- kafka
- data-stream
- kafka-streams
- +14 more
+22 stars
from 2,155 · score 3.14
208.asaskevich / EventBus
[Go] Lightweight eventbus with async compatibility for Go
- event-driven
- golang
+22 stars
from 1,960 · score 3.14
209.zarusz / SlimMessageBus
Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.
+22 stars
from 639 · score 3.14
210.timbray / quamina
Home of Quamina, a fast pattern-matching library in Go
- event-driven
- go
- golang
- json
- events
+22 stars
from 487 · score 3.14
211.pancsta / asyncmachine-go
state machine which runs code
- golang
- workflows
- state-machine
- actor-model
- aop
- consensus
- +14 more
+22 stars
from 171 · score 3.14
212.emitter-io / emitter
High performance, distributed and low latency publish-subscribe platform.
- pubsub
- networking
- emitter
- mqtt
- mqtt-broker
- realtime
- +4 more
+21 stars
from 3,990 · score 3.09
213.litenova / LiteBus
Modular .NET messaging for commands, queries, events, durable inbox and outbox processing, sagas, and broker transports.
- cqrs
- cqs
- csharp
- dotnet-core
- mediator
- eventbus
- +3 more
+21 stars
from 217 · score 3.09
214.nnnkkk7 / snowflake-emulator
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
+21 stars
from 36 · score 3.09
215.php-amqplib / php-amqplib
The most widely used PHP client for RabbitMQ
+20 stars
from 4,579 · score 3.04
216.typelevel / fs2
Compositional, streaming I/O library for Scala
- scala
- stream
- streaming-computation
- fp
- functional-programming
+20 stars
from 2,436 · score 3.04
217.Ahoo-Wang / Wow
TranslatedModern Reactive CQRS Architecture Microservice development framework based on DDD and EventSourcing
- cqrs
- domain-driven-design
- event-driven
- event-sourcing
- microservice
- reactive-programming
- +13 more
+20 stars
from 285 · score 3.04
218.robinhood / faust
Python Stream Processing
- kafka-streams
- kafka
- python
- asyncio
- distributed-systems
- stream-processing
+19 stars
from 6,804 · score 3.00
219.DrmagicE / gmqtt
Gmqtt is a flexible, high-performance MQTT broker library that fully implements the MQTT protocol V3.x and V5 in golang
- mqtt
- mqtt-broker
- mqtt-protocol
- mqtt-server
- server
- gmqtt
- +1 more
+19 stars
from 1,034 · score 3.00
220.allegro / hermes
Fast and reliable message broker built on top of Kafka.
+19 stars
from 854 · score 3.00
221.linkedin / databus
Source-agnostic distributed change data capture system
+18 stars
from 3,667 · score 2.94
222.Netflix / mantis
A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications
+18 stars
from 1,456 · score 2.94
223.apache / livy
Apache Livy is an open source REST interface for interacting with Apache Spark from anywhere.
+18 stars
from 943 · score 2.94
224.zeromq / jeromq
JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
- jeromq
- libzmq
- messaging
- networking
- pubsub
- pushpull
- +4 more
+17 stars
from 2,437 · score 2.89
225.liyue201 / gostl
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
+17 stars
from 1,126 · score 2.89
226.krisleech / wisper
A micro library providing Ruby objects with Publish-Subscribe capabilities
- ruby
- events
- publish-subscribe
- pubsub
+16 stars
from 3,316 · score 2.83
227.apache / gobblin
A distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.
- data
- ingestion
- replication
- management
- apache
+16 stars
from 2,254 · score 2.83
+16 stars
from 1,809 · score 2.83
229.EchoVault / SugarDB
Embeddable and distributed in-memory alternative to Redis.
- cluster
- database
- distributed
- memory
- networking
- pubsub
- +13 more
+16 stars
from 523 · score 2.83
230.confluentinc / ksql
The database purpose-built for stream processing applications.
- stream-processing
- real-time
- sql
- interactive
- kafka
- kafka-connect
- +6 more
+16 stars
from 300 · score 2.83
231.chatnoir-eu / chatnoir-resiliparse
A robust web archive analytics toolkit
- python
- web
- warc
- bigdata
- extraction
- webarchive
- +2 more
+16 stars
from 137 · score 2.83
232.drt-hub / drt
Reverse ETL for the code-first data stack
- bigquery
- cli
- data-engineering
- dbt
- duckdb
- etl
- +14 more
+16 stars
from 20 · score 2.83
233.siddhi-io / siddhi
Stream Processing and Complex Event Processing Engine
- streaming-data-processing
- cep
- stream-processing
- complex-event-processing
- online-learning
- cloud-native
- +3 more
+15 stars
from 1,582 · score 2.77
234.linkedin / brooklin
An extensible distributed system for reliable nearline data streaming at scale
- distributed-systems
- data-streaming
- scalability
- kafka-mirror-maker
- kafka
- change-data-capture
- +2 more
+15 stars
from 958 · score 2.77
235.pipelinedb / pipelinedb
High-performance time-series aggregation for PostgreSQL
- realtime
- stream-processing
- analytics
- sql
- push
- postgresql
- +3 more
+14 stars
from 2,652 · score 2.71
236.alibaba / pipcook
Machine learning platform for Web developers
+14 stars
from 2,580 · score 2.71
237.Protocol-Lattice / GoEventBus
GoEventBus — high-performance event bus with a decision layer.
- golang
- library
- event-driven
- concurrency
- event-driven-architecture
- pubsub
- +8 more
+14 stars
from 61 · score 2.71
238.riemann / riemann
A network event stream processing system, in Clojure.
- riemann
- events
- clojure
- monitoring
- logging
- metrics
- +1 more
+13 stars
from 4,256 · score 2.64
239.mara / mara-pipelines
A lightweight opinionated ETL framework, halfway between plain scripts and Apache Airflow
- etl
- data-integration
- python
- postgresql
- pipeline
- data
+13 stars
from 2,078 · score 2.64
240.ruby-amqp / bunny
Bunny is a popular, easy to use, mature Ruby client for RabbitMQ
+13 stars
from 1,413 · score 2.64
+13 stars
from 1,303 · score 2.64
242.jf-tech / omniparser
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
+13 stars
from 1,073 · score 2.64
243.spring-cloud / spring-cloud-stream
Framework for building Event-Driven Microservices
- microservices
- messaging
- event-driven-microservices
- stream-processing
- reactive
- cloud-native
+13 stars
from 1,059 · score 2.64
244.LGouellec / streamiz
.NET Stream Processing Library for Apache Kafka 🚀
- kafka-streams-dotnet
- kafka-streams
- kafka-streams-net
- kafka
- event-streaming
- streamiz
+13 stars
from 531 · score 2.64
245.strimzi / strimzi-kafka-bridge
An HTTP bridge for Apache Kafka®
+13 stars
from 332 · score 2.64
246.Colin4k1024 / AetherisArchived
Execution runtime for intelligent agents with event-sourced, recoverable task orchestration.
- agent
- agents
- checkpointing
- dag
- engine
- event-sourcing
- +5 more
+13 stars
from 10 · score 2.64
247.ploomber / ploomberArchived
The fastest ⚡️ way to build data pipelines. Develop iteratively, deploy anywhere. ☁️
- workflow
- machine-learning
- data-science
- data-engineering
- mlops
- papermill
- +6 more
+12 stars
from 3,609 · score 2.56
248.airbnb / streamalert
StreamAlert is a serverless, realtime data analysis framework which empowers you to ingest, analyze, and alert on data from any environment, using datasources and alerting logic you define.
- security
- kinesis
- serverless
- terraform
- lambda
- aws
- +2 more
+12 stars
from 2,881 · score 2.56
249.apache / cassandra-spark-connector
Apache Spark to Apache Cassandra connector
+12 stars
from 1,943 · score 2.56
250.clj-commons / manifold
A compatibility layer for event-driven abstractions
- stream-processing
- future
- clojure
- async
- stream
+12 stars
from 1,044 · score 2.56
251.nanomsg / mangos
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
+12 stars
from 750 · score 2.56
252.mayuanyang / Mediator.Net
A simple mediator for .Net for sending command, publishing event and request response with pipelines supported
- mediator
- bus
- cqrs
- ddd
- csharp
- dotnet
- +1 more
+12 stars
from 524 · score 2.56
253.mikestefanello / backlite
Type-safe, persistent, embedded task queues and background job runner w/ SQLite. Web monitoring UI included.
- go
- golang
- job-queue
- job-scheduler
- jobs
- queue
- +13 more
+12 stars
from 145 · score 2.56
254.kzmlabs / flink-statefun
Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.
- actor-model
- apache-flink
- distributed-systems
- event-driven
- event-driven-architecture
- flink
- +14 more
+12 stars
from 1 · score 2.56
255.python-streamz / streamz
Real-time stream processing for python
- streaming-data
- python
- async
- real-time
+11 stars
from 1,295 · score 2.48
256.microsoft / Trill
Trill is a single-node query processor for temporal or streaming data.
- streaming-data
- temporal-data
+11 stars
from 1,264 · score 2.48
257.AgnostiqHQ / covalent
Pythonic tool for orchestrating machine-learning/high performance/quantum-computing workflows in heterogeneous compute environments.
- hpc
- workflow
- workflow-automation
- workflow-management
- quantum-computing
- hpc-applications
- +14 more
+11 stars
from 857 · score 2.48
258.gazette / core
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
- golang
- event-sourcing
- stream-processing
- brokers
- streaming-platforms
+11 stars
from 787 · score 2.48
259.pingcap / tiflow
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
+11 stars
from 454 · score 2.48
+11 stars
from 437 · score 2.48
261.mdbergmann / cl-gserver
Sento - Actor framework featuring actors and agents for easy access to state and asynchronous operations.
- common-lisp
- concurrency
- genserver
- actor
- reactive
- event-driven
+11 stars
from 250 · score 2.48
262.Cinchoo / ChoETL
ETL framework for .NET (Parser / Writer for CSV, Flat, Xml, JSON, Key-Value, Parquet, Yaml, Avro formatted files)
+10 stars
from 851 · score 2.40
263.tinode / webapp
Tinode web chat using React
- chat
- chat-application
- chatapp
- react
- tinode
- instant-messaging
- +6 more
+10 stars
from 352 · score 2.40
264.linkedin / isolation-forest
A distributed Spark/Scala implementation of the isolation forest and extended isolation forest algorithms for unsupervised outlier detection, featuring support for scalable training and ONNX export for easy cross-platform inference.
- isolation-forest
- spark
- outlier-detection
- unsupervised-learning
- machine-learning
- +3 more
+10 stars
from 255 · score 2.40
265.HALFpipe / HALFpipe
ENIGMA HALFpipe is a user-friendly software that facilitates reproducible analysis of fMRI data
- neuroimaging
- reproducibility
- pipeline
- meta-analysis
- bids
- fmri
+10 stars
from 121 · score 2.40
266.bottenderjs / messaging-apis
Messaging APIs for multi-platform
- messaging
- messenger
- line
- api-client
- chatbot
- slack
- +4 more
+9 stars
from 1,927 · score 2.30
267.Netflix / genie
Distributed Big Data Orchestration Service
- big-data
- bigdata
- orchestration
- configuration
- configuration-management
- java
- +7 more
+9 stars
from 1,759 · score 2.30
+9 stars
from 755 · score 2.30
269.weyoss / redis-smq
RedisSMQ: A high-performance Redis message queue for Node.js
- redis
- background-jobs
- brokers
- dead-letter-queue
- delayed-jobs
- distributed-systems
- +14 more
+9 stars
from 662 · score 2.30
270.1kbgz / tributary
Streaming reactive and dataflow graphs in Python
- python
- python3
- stream
- data-pipeline
- streaming
- asynchronous
- +5 more
+9 stars
from 458 · score 2.30
271.mustafaturan / bus
🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit
- eventbus
- message-bus
- pubsub
- message-broker
- go
- go-package
- +3 more
+9 stars
from 359 · score 2.30
272.jandelgado / rabtap
RabbitMQ wire tap and swiss army knife
- rabbitmq
- tap
- wiretap
- golang
- publish
- subscribe
- +3 more
+9 stars
from 281 · score 2.30
273.brunch / brunch
🍴 Web applications made easy. Since 2011.
+8 stars
from 6,746 · score 2.20
274.TIBCOSoftware / flogo
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
- flogo
- iot
- integration
- golang
- edge
- microservices
- +14 more
+8 stars
from 2,480 · score 2.20
275.message-db / message-db
Microservice native message and event store for Postgres
- event-store
- event-sourcing
- event-driven
- pub-sub
- event-stream
- message-queue
- +1 more
+8 stars
from 1,646 · score 2.20
276.pdpipe / pdpipe
Easy pipelines for pandas DataFrames.
- pandas
- pandas-dataframe
- pipeline
- data
- data-science
- dataframe
- +1 more
+8 stars
from 723 · score 2.20
277.mongodb / mongo-spark
The MongoDB Spark Connector
+8 stars
from 721 · score 2.20
278.sizovs / PipelinR
PipelinR is a lightweight command processing pipeline ❍ ⇢ ❍ ⇢ ❍ for your Java awesome app.
- java
- architecture
- service-layer
- pipes-and-filters
- mediator
- mediatr
- +5 more
+8 stars
from 485 · score 2.20
279.fieldryand / goflow
Simple but powerful DAG scheduler and dashboard
- directed-acyclic-graph
- airflow
- dashboard
- go
- job-scheduler
- schedule
- +1 more
+8 stars
from 476 · score 2.20
280.nilenso / goose
A powerful background job processing library for Clojure
+8 stars
from 307 · score 2.20
281.Breeze0806 / go-etl
go-etl is a toolset for data extraction, transformation and loading.
- etl
- mysql
- go
- postgresql
- greenplum
- csv
- +5 more
+8 stars
from 184 · score 2.20
+8 stars
from 56 · score 2.20
283.rulego / streamsql
Lightweight SQL-based stream processing engine for IoT edge.
+8 stars
from 56 · score 2.20
284.crossbario / crossbar
Crossbar.io - WAMP application router
+7 stars
from 2,054 · score 2.08
+7 stars
from 1,769 · score 2.08
+7 stars
from 373 · score 2.08
287.Overtorment / NoobHub
🌐🔥 Network multiplayer and messaging for CoronaSDK, Moai, Gideros, LÖVE & Defold
+7 stars
from 350 · score 2.08
288.SchwarzDigits / hypermatch
hypermatch is a high-performance ⚡ Go library designed for rapid matching of a large number of rules to events. It processes thousands of events per second 🚀 against extensive rule sets in-memory with minimal latency ⏱️.
- go
- golang
- matching
- matching-engine
- performance
- rule-engine
- +3 more
+7 stars
from 32 · score 2.08
+6 stars
from 1,779 · score 1.95
290.h2oai / sparkling-water
Sparkling Water provides H2O functionality inside Spark cluster
- h2o
- spark
- machine-learning
- integration
- pysparkling
- rsparkling
- +3 more
+6 stars
from 976 · score 1.95
+6 stars
from 838 · score 1.95
292.charlessolar / Aggregates.NET
.NET event sourced domain driven design model via NServiceBus and GetEventStore
- eventstore
- nservicebus
- ddd
- eventsourcing
- microservices
- cqrs
+6 stars
from 441 · score 1.95
293.smooks / smooks
An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration
- java
- smooks
- enterprise-integration
- etl
- sax
- pipelines
- +5 more
+6 stars
from 416 · score 1.95
294.eigr / spawn
Spawn - Actor Mesh
- actorsystem
- concurrency
- distributed-systems
- kubernetes
- sidecar
- actor-model
- +8 more
+6 stars
from 371 · score 1.95
295.neo4j / neo4j-spark-connector
Neo4j Connector for Apache Spark, which provides bi-directional read/write access to Neo4j from Spark, using the Spark DataSource APIs
- spark
- neo4j-connector
- cypher
- neo4j-driver
- bolt
- hacktoberfest
+6 stars
from 318 · score 1.95
296.mehdihadeli / Go-MediatR
🚃 A library for handling mediator patterns and simplified CQRS patterns within an event-driven architecture, inspired by csharp MediatR library.
- cqrs
- golang
- mediator
- mediator-pattern
- go
- golang-package
+6 stars
from 276 · score 1.95
297.chronicle-app / chronicle-etl
📜 A CLI toolkit for extracting and working with your digital history
+6 stars
from 194 · score 1.95
298.SomajitDey / ipfs-chat
Real-time P2P messenger using go-ipfs pubsub. TUI. End-to-end encrypted texting & file-sharing. NAT traversal.
- p2p
- tui
- ipfs
- pubsub
- serverless
- dht
- +14 more
+6 stars
from 149 · score 1.95
299.AdaCore / RecordFlux
Formal specification and generation of verifiable binary parsers, message generators and protocol state machines
- parser
- binary-parser
- ada
- spark
- formal-verification
- formal-specification
- +5 more
+6 stars
from 125 · score 1.95
300.groda / big_data
Big Data essentials: Hadoop, MapReduce, Spark. Explore tutorials and demos in Jupyter notebooks—most are self-contained and live, ready to run with a click.
+6 stars
from 83 · score 1.95