+3 stars
from 145 · score 1.39
Trending repositories
Ranked by Attention Score: stars gained over the last 90 complete days
301–400 of 407 by Attention Score · Aug 6, 2026 – Nov 3, 2026 (UTC)
302.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
+3 stars
from 128 · score 1.39
303.HALFpipe / HALFpipe
ENIGMA HALFpipe is a user-friendly software that facilitates reproducible analysis of fMRI data
- neuroimaging
- reproducibility
- pipeline
- meta-analysis
- bids
- fmri
+3 stars
from 128 · score 1.39
+3 stars
from 61 · score 1.39
305.rulego / streamsql
Lightweight SQL-based stream processing engine for IoT edge.
+3 stars
from 61 · score 1.39
306.galax-io / gatling-kafka-plugin
Gatling plugin for Apache Kafka — produce, request-reply, and consume load testing with Avro, Protobuf, and Schema Registry support
- gatling
- kafka
- performance
- performance-testing
- avro
- java
- +5 more
+3 stars
from 22 · score 1.39
307.apache / incubator-heronArchived
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
+2 stars
from 3,621 · score 1.10
+2 stars
from 3,482 · score 1.10
309.asaskevich / EventBus
[Go] Lightweight eventbus with async compatibility for Go
- event-driven
- golang
+2 stars
from 1,980 · score 1.10
310.bottenderjs / messaging-apis
Messaging APIs for multi-platform
- messaging
- messenger
- line
- api-client
- chatbot
- slack
- +4 more
+2 stars
from 1,934 · score 1.10
311.pinterest / secorArchived
Secor is a service implementing Kafka log persistence
+2 stars
from 1,856 · score 1.10
+2 stars
from 1,783 · score 1.10
313.tylertreat / BoomFilters
Probabilistic data structures for processing continuous, unbounded streams.
- bloom-filter
- go
- stable-bloom-filters
- cuckoo-filter
- probabilistic-programming
- counting-bloom-filters
- +4 more
+2 stars
from 1,645 · score 1.10
314.ruby-amqp / bunny
Bunny is a popular, easy to use, mature Ruby client for RabbitMQ
+2 stars
from 1,424 · score 1.10
315.killme2008 / Metamorphosis
A high available,high performance distributed messaging system.
+2 stars
from 1,326 · score 1.10
316.uber-archive / AthenaXArchived
SQL-based streaming analytics platform at scale
+2 stars
from 1,221 · score 1.10
317.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
+2 stars
from 866 · score 1.10
318.doujiang24 / lua-resty-kafka
Lua kafka client driver for the Openresty based on the cosocket API
+2 stars
from 812 · score 1.10
319.pdpipe / pdpipe
Easy pipelines for pandas DataFrames.
- pandas
- pandas-dataframe
- pipeline
- data
- data-science
- dataframe
- +1 more
+2 stars
from 729 · score 1.10
320.LineaLabs / lineapy
Move fast from data science prototype to pipeline. Capture, analyze, and transform messy notebooks into data pipelines with just two lines of code.
+2 stars
from 669 · score 1.10
321.nats-io / nats.net.v1
The official C# Client for NATS
+2 stars
from 651 · score 1.10
322.uxlfoundation / oneDAL
oneAPI Data Analytics Library (oneDAL)
- onedal
- data-analysis
- oneapi
- machine-learning
- machine-learning-algorithms
- hacktoberfest
- +8 more
+2 stars
from 651 · score 1.10
323.yahoo / streaming-benchmarks
Benchmarks for Low Latency (Streaming) solutions including Apache Storm, Apache Spark, Apache Flink, ...
- benchmarks
- low-latency
- streaming
+2 stars
from 645 · score 1.10
324.scalecube / scalecube-services
Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing
- microservices
- reactive-streams
- distributed-systems
- service-mesh
- reactive-microservices
- ipc
- +14 more
+2 stars
from 637 · score 1.10
325.elpheria / rpc-websockets
JSON-RPC 2.0 implementation over WebSockets for Node.js and JavaScript/TypeScript
- rpc-api
- rpc-framework
- rpc-client
- rpc-server
- websocket-server
- rpc
- +14 more
+2 stars
from 624 · score 1.10
326.CrowdHailer / OK
Elegant error/exception handling in Elixir, with result monads.
- pipeline
- monad
- macros
- elixir
- elixir-pipelines
+2 stars
from 605 · score 1.10
327.andreschaffer / event-sourcing-cqrs-examples
Event Sourcing and CQRS in practice.
- event-sourcing
- cqrs
- ddd
- domain-driven-design
- hexagonal-architecture
- events
- +3 more
+2 stars
from 597 · score 1.10
328.Esri / gis-tools-for-hadoop
The GIS Tools for Hadoop are a collection of GIS tools for spatial analysis of big data.
- spatial-analysis
- hadoop
+2 stars
from 522 · score 1.10
329.1kbgz / tributary
Streaming reactive and dataflow graphs in Python
- python
- python3
- stream
- data-pipeline
- streaming
- asynchronous
- +5 more
+2 stars
from 465 · score 1.10
330.rdagumampan / yuniql
Free and open source schema versioning and database migration made natively with .NET/6. NEW THIS MAY 2022! v1.3.15 released!
- sql
- yuniql
- database-migrations
- sqlserver
- postgresql
- mariadb
- +10 more
+2 stars
from 428 · score 1.10
331.tigase / tigase-server
Highly optimized, extremely modular and very flexible XMPP/Jabber server
- tigase
- xmpp
- server
- java
- jabber
- iot
- +7 more
+2 stars
from 356 · score 1.10
332.Overtorment / NoobHub
🌐🔥 Network multiplayer and messaging for CoronaSDK, Moai, Gideros, LÖVE & Defold
+2 stars
from 355 · score 1.10
333.grai-io / grai-core
The repository host gives no description.
- hacktoberfest
- data
- datalineage
- dbt
- open-source
- postgresql
- +11 more
+2 stars
from 315 · score 1.10
+2 stars
from 313 · score 1.10
335.jandelgado / rabtap
RabbitMQ wire tap and swiss army knife
- rabbitmq
- tap
- wiretap
- golang
- publish
- subscribe
- +3 more
+2 stars
from 288 · score 1.10
+2 stars
from 248 · score 1.10
337.mariomac / gostream
A Go port of the Java Streams API. Type-safe and functional Go Streams processing
- golang
- go
- stream-processing
- generics
- type-parameters
+2 stars
from 172 · score 1.10
338.helgeho / ArchiveSpark
An Apache Spark framework for easy data processing, extraction as well as derivation for web archives and archival collections, developed at Internet Archive.
- archivespark
- spark-framework
- spark
- web-archiving
- webarchive
- internet-archive
- +1 more
+2 stars
from 162 · score 1.10
339.archivesunleashed / aut
The Archives Unleashed Toolkit is an open-source toolkit for analyzing web archives.
- spark
- hadoop
- webarchives
- analysis
- apache-spark
- scala
- +8 more
+2 stars
from 157 · score 1.10
340.Steema / TeeBI
Data-mining and Visualization components for RAD Studio
- visualization
- complex-structures
- database
- charting-library
- multidimensional-data
- query-engine
- +7 more
+2 stars
from 150 · score 1.10
341.beava-dev / beava
Real-time decision features without streaming infra. Turn live events into product reflexes — no Kafka, no Flink, no feature store.
- analytics
- feature-store
- fraud-detection
- python
- real-time
- rust
- +4 more
+2 stars
from 137 · score 1.10
342.Timmoth / AsyncMonolith
Facilitates simple durable and asynchronous messaging in dotnet apps.
+2 stars
from 90 · score 1.10
343.docandrew / CuBit
General-purpose, formally-verified, 64-bit operating system in SPARK/Ada for x86-64
+2 stars
from 88 · score 1.10
344.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.
+2 stars
from 87 · score 1.10
345.joseferben / pocketbase-queue
A type-safe queue for background tasks using PocketBase.
- background-jobs
- pocketbase
- queue
- typescript
- workers
+2 stars
from 62 · score 1.10
346.tejzpr / ordered-concurrently
Ordered-concurrently a library for concurrent processing with ordered output in Go. Process work concurrently and returns output in a channel in the order of input. It is useful in concurrently processing items in a queue, and get output in the order provided by the queue.
- concurrent
- golang
- golang-library
- data-science
- data-pipeline
- parallel-computing
- +3 more
+2 stars
from 46 · score 1.10
347.wisp-trading / wisp
Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets
- algorithmic-trading
- cryptocurrency
- event-driven
- go
- golang
- trading-algorithms
- +2 more
+2 stars
from 12 · score 1.10
348.qvcloud / broker
A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.
+2 stars
from 11 · score 1.10
349.galax-io / gatling-amqp-plugin
Gatling plugin for AMQP/RabbitMQ — publish, request-reply, and consume patterns with connection pooling
- amqp
- gatling
- gatling-plugin
- performance
- performance-testing
- java
- +5 more
+2 stars
from 7 · score 1.10
350.godalida / koala-diff
Blazingly fast data comparison tool for Python, powered by Rust. Compare massive CSV/Parquet datasets instantly.
- csv
- data-engineering
- data-quality
- diff
- high-performance
- parquet
- +4 more
+2 stars
from 7 · score 1.10
351.mgillr / crdt-merge
Conflict-free merge for DataFrames, JSON, ML models & distributed agents — powered by CRDTs. The first merge library where every operation is mathematically guaranteed to converge.
- collaborative-editing
- conflict-resolution
- crdt
- data-engineering
- data-synchronization
- distributed-systems
- +14 more
+2 stars
from 5 · score 1.10
352.dataspoclab / dataspoc-pipe
Data ingestion engine — Singer taps to Parquet in cloud buckets
- data
- data-engineering
- data-lake
- duckdb
- etl
- parquet
- +3 more
+2 stars
from 2 · score 1.10
353.chrislusf / glow
Glow is an easy-to-use distributed computation system written in Go, similar to Hadoop Map Reduce, Spark, Flink, Storm, etc. I am also working on another similar pure Go system, https://github.com/chrislusf/gleam , which is more flexible and more performant.
+1 stars
from 3,215 · score 0.69
354.spark-jobserver / spark-jobserver
REST job server for Apache Spark
+1 stars
from 2,832 · score 0.69
355.Yelp / mrjob
Run MapReduce jobs on Hadoop or Amazon Web Services
+1 stars
from 2,612 · score 0.69
356.nats-io / nats-streaming-serverArchived
NATS Streaming System Server
+1 stars
from 2,521 · score 0.69
357.crossbario / crossbar
Crossbar.io - WAMP application router
+1 stars
from 2,060 · score 0.69
358.onyx-platform / onyxArchived
Distributed, masterless, high performance, fault tolerant data processing
- clojure
- distributed
- streaming
- batch
- data
+1 stars
from 2,048 · score 0.69
+1 stars
from 1,546 · score 0.69
360.lukasmartinelli / pgfutter
Import CSV and JSON into PostgreSQL the easy way
+1 stars
from 1,343 · score 0.69
361.lensacom / sparkit-learn
PySpark + Scikit-learn = Sparkit-learn
+1 stars
from 1,149 · score 0.69
362.hazelcast / hazelcast-jetArchived
Distributed Stream and Batch Processing
- java
- big-data
- stream-processing
- batch-processing
- event-processing
- low-latency
- +3 more
+1 stars
from 1,110 · score 0.69
363.gearpump / gearpump
Lightweight real-time big data streaming engine over Apache Pekko
- akka
- stream-processing
- bigdata
- scala
+1 stars
from 755 · score 0.69
364.jakubkulhan / bunny
Performant pure-PHP AMQP (RabbitMQ) sync/async (ReactPHP) library
- amqp
- amqp-client
- amqp0-9-1
- php
- php-library
- rabbitmq
+1 stars
from 746 · score 0.69
365.otobus / event_bus
:surfer: Traceable, extendable and minimalist **event bus** implementation for Elixir with built-in **event store** and **event watcher** based on ETS.
- elixir
- eventbus
- event-sourcing
- eventstore
- message-bus
- instrumentation
+1 stars
from 703 · score 0.69
366.xuri / aurora
Cross-platform beanstalkd queue server admin console.
- aurora
- go
- beanstalkd
- bstk
- console
- admin
- +3 more
+1 stars
from 599 · score 0.69
367.OrleansContrib / Orleankka
Functional API for Microsoft Orleans http://orleanscontrib.github.io/Orleankka
- actors
- cqrs
- event-sourcing
- fsm
- orleans
- functional
+1 stars
from 505 · score 0.69
368.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
+1 stars
from 492 · score 0.69
369.boostercloud / booster
Booster Framework
- serverless
- cloud-native
- booster-framework
- typescript
- event-driven
- event-sourcing
- +9 more
+1 stars
from 446 · score 0.69
370.AntonioFalcaoJr / EventualShop
A state-of-the-art distributed system using Reactive DDD as uncertainty modeling, Event Storming as subdomain decomposition, Event Sourcing as an eventual persistence mechanism, CQRS, Async Projections, Microservices for individual deployable units, Event-driven Architecture for efficient integration, and Clean Architecture as domain-centric design
- cqrs
- ddd
- clean-architecture
- event-sourcing
- event-driven
- eda
- +14 more
+1 stars
from 423 · score 0.69
371.itlibrium / DDD-starter-dotnet
Sample implementation and comparison of various approaches to building DDD applications. Useful as a baseline to quickly start a DDD dot net project.
- ddd
- ddd-example
- ddd-patterns
- hexagonal-architecture
- bdd
- event-sourcing
- +1 more
+1 stars
from 404 · score 0.69
372.yevhen / Streamstone
Event store for Azure Table Storage
+1 stars
from 401 · score 0.69
373.Code-Sharp / WampSharp
A C# implementation of WAMP (The Web Application Messaging Protocol)
+1 stars
from 388 · score 0.69
374.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
+1 stars
from 367 · score 0.69
375.TeaEntityLab / fpGo
Monad, Functional Programming features for Golang
- golang
- functional-programming
- functional-reactive-programming
- reactive
- reactive-programming
- golang-library
- +14 more
+1 stars
from 354 · score 0.69
376.davidesantangelo / api.rssArchived
RSS as RESTful. This service allows you to transform RSS feed into an awesome API.
+1 stars
from 346 · score 0.69
377.xitonix / trubka
A CLI tool for Kafka
+1 stars
from 336 · score 0.69
378.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
+1 stars
from 323 · score 0.69
379.dereuromark / cakephp-queue
Queue plugin for CakePHP - simple, pure PHP and without dependencies.
- asynchronous
- background-jobs
- cronjob
- queue
- cakephp
- cakephp-plugin
- +1 more
+1 stars
from 308 · score 0.69
380.larpon / QtFirebase
An effort to bring Google's Firebase C++ API to Qt + QML
+1 stars
from 290 · score 0.69
381.vardius / message-bus
Go simple async message bus
- message-bus
- event-sourcing
- ddd
- async
- message-queue
- message-broker
- +4 more
+1 stars
from 283 · score 0.69
382.BEagle1984 / silverback
Silverback is a message bus and broker integration library for .NET. It is designed to simplify event-driven architectures and asynchronous messaging, with first-class support for Apache Kafka and MQTT.
- microservice
- messaging
- kafka
- silverback
- message-bus
- message-brokers
- +6 more
+1 stars
from 282 · score 0.69
383.dbcli / athenacli
AthenaCLI is a CLI tool for AWS Athena service that can do auto-completion and syntax highlighting.
- aws-cli
- athena-cli
- aws-athena
- python
- bigdata
- syntax-highlighting
- +3 more
+1 stars
from 227 · score 0.69
+1 stars
from 224 · score 0.69
385.monksy / awesome-kafka
A collection of kafka-resources
- kafka
- kafka-streams
- awesome
- awesome-list
- awesome-lists
+1 stars
from 215 · score 0.69
386.edwingeng / deque
A highly optimized double-ended queue
+1 stars
from 203 · score 0.69
387.eulerfx / DDDInventoryItemFSharp
Event-Sourcing and Domain-Driven Design with F# and EventStore
+1 stars
from 186 · score 0.69
388.friflo / Friflo.Json.Fliox
C# ORM - High Performance, SQL, NoSQL, Messaging, Pub-Sub
- pub-sub
- netcode
- orm
- csharp
- asp-net-core
- realtime-messaging
- +2 more
+1 stars
from 185 · score 0.69
389.seung-lab / cloud-volume
Read and write Neuroglancer datasets programmatically.
+1 stars
from 175 · score 0.69
390.synacker / daggy
Daggy - Data Aggregation Utility and C/C++ developer library for data streams catching
- serverless-framework
- streaming
- stream-processing
- qt
- aggregation
- process
- +7 more
+1 stars
from 165 · score 0.69
391.spreedly / kaffe
An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.
- elixir
- kafka
+1 stars
from 164 · score 0.69
392.danieleteti / delphistompclient
STOMP client for Embarcadero Delphi and FreePascal.
- stomp
- delphi
- activemq
- pascal
- embarcadero-delphi
- rabbitmq
+1 stars
from 146 · score 0.69
393.embano1 / memlog
A Kafka log inspired in-memory and append-only data structure
+1 stars
from 142 · score 0.69
394.eosrio / hyperion-history-api
Scalable Full History API Solution for Antelope (former EOSIO) based blockchains
- antelope
- api
- big-data
- blockchain
- elasticsearch
- eos
- +10 more
+1 stars
from 135 · score 0.69
395.joel-jeremy / emissary
Emissary is simple, yet 🗲FAST🗲 messaging library for decoupling messages (requests and events) and message handlers 🚀
- java
- jvm
- messaging
- requests
- dispatcher
- event
- +2 more
+1 stars
from 109 · score 0.69
396.ballerina-platform / module-ballerina-mqtt
Ballerina MQTT Module.
+1 stars
from 104 · score 0.69
397.flipkart-incubator / hbase-orm
A production-grade HBase ORM library that makes accessing HBase clean, fast and fun (Can also be used as Bigtable ORM)
- hbase
- orm
- mapreduce
- object-mapping
- hbase-orm
- bigtable
- +3 more
+1 stars
from 83 · score 0.69
398.ddd-cqrs-es / community
Docs related to DDD-CQRS-ES Discord Community
- community
- cqrs
- ddd
- event-sourcing
+1 stars
from 81 · score 0.69
399.ambster-public / awesome-qlik
A curated list of awesome Qlik extensions and resources for Qlik Sense and QlikView
- qlik
- qlik-sense
- qlik-extension
- qlik-sense-extension
- qliksense
- qlikview
- +14 more
+1 stars
from 78 · score 0.69
400.capillariesio / capillaries
Distributed batch data processing framework
- cassandra
- rabbitmq
- go
- batch-processing
- dag
- distributed-computing
- +5 more
+1 stars
from 73 · score 0.69