201.timbray / quamina
Home of Quamina, a fast pattern-matching library in Go
- event-driven
- go
- golang
- json
- events
+11 stars
from 498 · score 2.48
Trending repositories
Ranked by Attention Score: stars gained over the last 90 complete days
201–300 of 411 by Attention Score · Aug 6, 2026 – Nov 3, 2026 (UTC)
202.littlehorse-enterprises / littlehorse
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
- microservices
- workflow-engine
- orchestration
- apache-kafka
- event-driven-architecture
- kafka-streams
- +1 more
+11 stars
from 390 · score 2.48
203.subquery / subql
SubQuery is an Open, Flexible, Fast and Universal data indexing framework for web3. Our mission is to help developers create the decentralised products of the future.
+10 stars
from 18,713 · score 2.40
204.emitter-io / emitter
High performance, distributed and low latency publish-subscribe platform.
- pubsub
- networking
- emitter
- mqtt
- mqtt-broker
- realtime
- +4 more
+10 stars
from 4,001 · score 2.40
205.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
+10 stars
from 1,203 · score 2.40
206.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
+10 stars
from 963 · score 2.40
207.indeedeng / iwf
iWF is a Workflow-As-Code microservice orchestration platform offering an orchestration coding framework and service for building resilient, fault-tolerant, scalable long-running processes
- golang
- workflow
- distributed-system
- orchestration
- orchestrator
- workflow-as-code
- +11 more
+10 stars
from 653 · score 2.40
208.unum-cloud / UStore
Multi-Modal Database replacing MongoDB, Neo4J, and Elastic with 1 faster ACID solution, with NetworkX and Pandas interfaces, and bindings for C 99, C++ 17, Python 3, Java, GoLang 🗄️
- acid
- database
- key-value-store
- document-database
- graph-database
- json
- +14 more
+10 stars
from 636 · score 2.40
209.Stiffstream / sobjectizer
An implementation of Actor, Publish-Subscribe, and CSP models in one rather small C++ framework. With performance, quality, and stability proved by years in the production.
- cpp
- cplusplus
- cplusplus-17
- actor-model
- actors
- actor-framework
- +13 more
+10 stars
from 618 · score 2.40
210.pancsta / asyncmachine-go
state machine which runs code
- golang
- workflows
- state-machine
- actor-model
- aop
- consensus
- +14 more
+10 stars
from 183 · score 2.40
211.chatnoir-eu / chatnoir-resiliparse
A robust web archive analytics toolkit
- python
- web
- warc
- bigdata
- extraction
- webarchive
- +2 more
+10 stars
from 143 · score 2.40
212.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
+10 stars
from 41 · score 2.40
213.krisleech / wisper
A micro library providing Ruby objects with Publish-Subscribe capabilities
- ruby
- events
- publish-subscribe
- pubsub
+9 stars
from 3,323 · score 2.30
214.datafold / data-diffArchived
Compare tables within or across databases
- database
- mysql
- postgresql
- snowflake
- rdbms
- trino
- +14 more
+9 stars
from 2,979 · score 2.30
215.microsoft / GraphEngineArchived
Microsoft Graph Engine
- graph-engine
- graph-query-language
- in-memory-storage
- in-memory-computations
- distributed-computing
- dotnet
+9 stars
from 2,255 · score 2.30
216.Netflix / mantis
A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications
+9 stars
from 1,465 · score 2.30
217.microsoft / Trill
Trill is a single-node query processor for temporal or streaming data.
- streaming-data
- temporal-data
+9 stars
from 1,266 · score 2.30
218.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
+9 stars
from 1,044 · score 2.30
219.allegro / hermes
Fast and reliable message broker built on top of Kafka.
+9 stars
from 864 · score 2.30
220.gammazero / deque
Fast ring-buffer deque (double-ended queue)
- deque
- queue
- ring-buffer
- circular-buffer
- circular-queue
+9 stars
from 781 · score 2.30
221.nanomsg / mangos
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
+9 stars
from 753 · score 2.30
222.adrianbrad / queue
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
- generic
- golang
- queue
- thread-safe
- go
- blocking-queue
- +3 more
+9 stars
from 362 · score 2.30
223.aregtech / areg-sdk
Distributed C++ services from embedded to enterprise
+9 stars
from 359 · score 2.30
224.drt-hub / drt
Reverse ETL for the code-first data stack
- bigquery
- cli
- data-engineering
- dbt
- duckdb
- etl
- +14 more
+9 stars
from 27 · score 2.30
225.pipelinedb / pipelinedb
High-performance time-series aggregation for PostgreSQL
- realtime
- stream-processing
- analytics
- sql
- push
- postgresql
- +3 more
+8 stars
from 2,658 · score 2.20
226.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
+8 stars
from 2,446 · score 2.20
227.liyue201 / gostl
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
+8 stars
from 1,135 · score 2.20
228.aelassas / wexflow
Workflow Automation Engine
- workflow-engine
- workflow
- cross-platform
- automation
- wexflow
- csharp
- +3 more
+8 stars
from 836 · score 2.20
229.andreiavrammsd / cpp-channel
C++11 thread-safe container for sharing data between threads (synchronized queue)
- cpp
- multithreading
- thread-safe
- channel
- concurrent-queue
- queue
- +2 more
+8 stars
from 588 · score 2.20
230.strimzi / strimzi-kafka-bridge
An HTTP bridge for Apache Kafka®
+8 stars
from 337 · score 2.20
231.robinhood / faust
Python Stream Processing
- kafka-streams
- kafka
- python
- asyncio
- distributed-systems
- stream-processing
+7 stars
from 6,816 · score 2.08
232.apache / cassandra-spark-connector
Apache Spark to Apache Cassandra connector
+7 stars
from 1,948 · score 2.08
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
+7 stars
from 1,590 · score 2.08
+7 stars
from 1,309 · score 2.08
235.gvinciguerra / PGM-index
🏅State-of-the-art learned data structure that enables fast lookup, predecessor, range searches and updates in arrays of billions of items using orders of magnitude less space than traditional indexes
- data-structures
- database
- cpp
- research
- indexing
- big-data
- +8 more
+7 stars
from 871 · score 2.08
236.MrPowers / chispa
PySpark test helper methods with beautiful error messages
+7 stars
from 770 · score 2.08
237.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
+7 stars
from 738 · score 2.08
238.EchoVault / SugarDB
Embeddable and distributed in-memory alternative to Redis.
- cluster
- database
- distributed
- memory
- networking
- pubsub
- +13 more
+7 stars
from 532 · score 2.08
239.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
+7 stars
from 254 · score 2.08
240.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
+7 stars
from 150 · score 2.08
241.Colin4k1024 / AetherisArchived
Execution runtime for intelligent agents with event-sourced, recoverable task orchestration.
- agent
- agents
- checkpointing
- dag
- engine
- event-sourcing
- +5 more
+7 stars
from 16 · score 2.08
242.php-amqplib / php-amqplib
The most widely used PHP client for RabbitMQ
+6 stars
from 4,593 · score 1.95
243.riemann / riemann
A network event stream processing system, in Clojure.
- riemann
- events
- clojure
- monitoring
- logging
- metrics
- +1 more
+6 stars
from 4,263 · score 1.95
244.ploomber / ploomberArchived
The fastest ⚡️ way to build data pipelines. Develop iteratively, deploy anywhere. ☁️
- workflow
- machine-learning
- data-science
- data-engineering
- mlops
- papermill
- +6 more
+6 stars
from 3,615 · score 1.95
245.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
+6 stars
from 2,264 · score 1.95
246.karafka / karafka
Ruby and Rails efficient Kafka processing framework
- karafka-framework
- kafka
- kafka-client
- kafka-clients
- kafka-producer
- kafka-consumer
- +14 more
+6 stars
from 2,247 · score 1.95
247.mara / mara-pipelines
A lightweight opinionated ETL framework, halfway between plain scripts and Apache Airflow
- etl
- data-integration
- python
- postgresql
- pipeline
- data
+6 stars
from 2,085 · score 1.95
248.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
+6 stars
from 1,648 · score 1.95
249.jf-tech / omniparser
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
+6 stars
from 1,080 · score 1.95
250.spring-cloud / spring-cloud-stream
Framework for building Event-Driven Microservices
- microservices
- messaging
- event-driven-microservices
- stream-processing
- reactive
- cloud-native
+6 stars
from 1,066 · score 1.95
251.clj-commons / manifold
A compatibility layer for event-driven abstractions
- stream-processing
- future
- clojure
- async
- stream
+6 stars
from 1,050 · score 1.95
252.apache / livy
Apache Livy is an open source REST interface for interacting with Apache Spark from anywhere.
+6 stars
from 955 · score 1.95
253.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
254.tinode / webapp
Tinode web chat using React
- chat
- chat-application
- chatapp
- react
- tinode
- instant-messaging
- +6 more
+6 stars
from 356 · score 1.95
255.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
+6 stars
from 232 · score 1.95
256.Protocol-Lattice / GoEventBus
GoEventBus — high-performance event bus with a decision layer.
- golang
- library
- event-driven
- concurrency
- event-driven-architecture
- pubsub
- +8 more
+6 stars
from 69 · score 1.95
257.rbmuller / scherlok
A detective for your data. Zero-config data quality monitoring — works with dbt, Postgres, BigQuery, Snowflake. No YAML.
- anomaly-detection
- bigquery
- cli
- data-engineering
- data-observability
- data-quality
- +14 more
+6 stars
from 7 · score 1.95
258.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
+5 stars
from 2,888 · score 1.79
259.liftbridge-io / liftbridge
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
+5 stars
from 2,799 · score 1.79
260.Netflix / genie
Distributed Big Data Orchestration Service
- big-data
- bigdata
- orchestration
- configuration
- configuration-management
- java
- +7 more
+5 stars
from 1,763 · score 1.79
261.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
+5 stars
from 531 · score 1.79
+5 stars
from 443 · score 1.79
263.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
+5 stars
from 417 · score 1.79
264.wso2 / product-ei
An open source, a high-performance hybrid integration platform that allows developers quick integration with any application, data, or system.
- integration
- middleware
- wso2
- esb
- messaging
- business-process
- +5 more
+5 stars
from 398 · score 1.79
265.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
+5 stars
from 300 · score 1.79
266.chronicle-app / chronicle-etl
📜 A CLI toolkit for extracting and working with your digital history
+5 stars
from 195 · score 1.79
267.alibaba / pipcook
Machine learning platform for Web developers
+4 stars
from 2,590 · score 1.61
268.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
+4 stars
from 2,484 · score 1.61
+4 stars
from 1,772 · score 1.61
270.hi-primus / optimus
:truck: Agile Data Preparation Workflows made easy with Pandas, Dask, cuDF, Dask-cuDF, Vaex and PySpark
- spark
- pyspark
- data-wrangling
- bigdata
- big-data-cleaning
- data-science
- +13 more
+4 stars
from 1,531 · score 1.61
271.WallarooLabs / wally
Distributed Stream Processing
- stream-processing
- stream-processor
- stream-processing-engine
- pony-language
- python
- linux
- +4 more
+4 stars
from 1,482 · score 1.61
272.PatMartin / Dex
Dex : The Data Explorer -- A data visualization tool written in Java/Groovy/JavaFX capable of powerful ETL and publishing web visualizations.
- data-science
- data-visualization
- visualization
- data-analysis
- data-mining
- java
- +7 more
+4 stars
from 1,314 · score 1.61
273.python-streamz / streamz
Real-time stream processing for python
- streaming-data
- python
- async
- real-time
+4 stars
from 1,302 · score 1.61
274.Cinchoo / ChoETL
ETL framework for .NET (Parser / Writer for CSV, Flat, Xml, JSON, Key-Value, Parquet, Yaml, Avro formatted files)
+4 stars
from 857 · score 1.61
275.mrpowers-io / quinn
pyspark methods to enhance developer productivity 📣 👯 🎉
+4 stars
from 686 · score 1.61
276.pingcap / tiflow
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
+4 stars
from 461 · score 1.61
+4 stars
from 376 · score 1.61
278.eigr / spawn
Spawn - Actor Mesh
- actorsystem
- concurrency
- distributed-systems
- kubernetes
- sidecar
- actor-model
- +8 more
+4 stars
from 373 · score 1.61
279.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
+4 stars
from 278 · score 1.61
280.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
+4 stars
from 261 · score 1.61
281.mostafa / xk6-kafka
k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond
+4 stars
from 215 · score 1.61
282.PierreCapo / treeviz
Tree diagrams with JavaScript :evergreen_tree: :chart_with_upwards_trend:
- tree
- javascript
- visualization
- big-data
- hierarchy
- family-tree
- +1 more
+4 stars
from 172 · score 1.61
283.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
+4 stars
from 35 · score 1.61
284.brunch / brunch
🍴 Web applications made easy. Since 2011.
+3 stars
from 6,751 · score 1.39
+3 stars
from 4,380 · score 1.39
286.elastic / elasticsearch-hadoop
:elephant: Elasticsearch real-time search and analytics natively integrated with Hadoop
+3 stars
from 1,964 · score 1.39
287.h2oai / sparkling-water
Sparkling Water provides H2O functionality inside Spark cluster
- h2o
- spark
- machine-learning
- integration
- pysparkling
- rsparkling
- +3 more
+3 stars
from 979 · score 1.39
288.chat-sdk / chat-sdk-ios
Chat SDK iOS - Open Source Mobile Messenger
+3 stars
from 917 · score 1.39
289.gazette / core
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
- golang
- event-sourcing
- stream-processing
- brokers
- streaming-platforms
+3 stars
from 795 · score 1.39
290.dopebase / messenger-iOS-chat-swift-firestore
Messenger Clone - Real-time iOS Chat with Firebase Firestore written in Swift
+3 stars
from 786 · score 1.39
291.slashdotdash / awesome-elixir-cqrs
A curated list of awesome Elixir and Command Query Responsibility Segregation (CQRS) resources.
- elixir
- cqrs
- event-sourcing
- domain-driven-design
- cqrs-es
- cqrs-framework
+3 stars
from 739 · score 1.39
292.mongodb / mongo-spark
The MongoDB Spark Connector
+3 stars
from 726 · score 1.39
293.hamed-shirbandi / TaskoMask
Task management system based on .NET 8 with Microservices, DDD, CQRS, Event Sourcing and Testing Concepts
- ddd
- event-sourcing
- cqrs
- bdd
- microservices
- clean-architechture
- +14 more
+3 stars
from 717 · score 1.39
294.ankurchavda / SparkLearning
A comprehensive Spark guide collated from multiple sources that can be referred to learn more about Spark or as an interview refresher.
+3 stars
from 686 · score 1.39
295.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
+3 stars
from 668 · score 1.39
296.LGouellec / streamiz
.NET Stream Processing Library for Apache Kafka 🚀
- kafka-streams-dotnet
- kafka-streams
- kafka-streams-net
- kafka
- event-streaming
- streamiz
+3 stars
from 541 · score 1.39
297.fieldryand / goflow
Simple but powerful DAG scheduler and dashboard
- directed-acyclic-graph
- airflow
- dashboard
- go
- job-scheduler
- schedule
- +1 more
+3 stars
from 481 · score 1.39
298.confluentinc / ksql
The database purpose-built for stream processing applications.
- stream-processing
- real-time
- sql
- interactive
- kafka
- kafka-connect
- +6 more
+3 stars
from 313 · score 1.39
299.nilenso / goose
A powerful background job processing library for Clojure
+3 stars
from 312 · score 1.39
300.FirelyTeam / spark
Firely and Incendi's open source FHIR server
- fhir
- spark
- stu3
- r4
- c-sharp
- fhir-server
- +12 more
+3 stars
from 282 · score 1.39