201.robinhood / faust
Python Stream Processing
- kafka-streams
- kafka
- python
- asyncio
- distributed-systems
- stream-processing
+3 stars
from 6,820 · score 1.39
Trending repositories
Ranked by Attention Score: stars gained over the last 30 complete days
201–300 of 344 by Attention Score · Oct 5, 2026 – Nov 3, 2026 (UTC)
202.aws / aws-sdk-pandas
pandas on AWS - Easy integration with Athena, Glue, Redshift, Timestream, Neptune, OpenSearch, QuickSight, Chime, CloudWatchLogs, DynamoDB, EMR, SecretManager, PostgreSQL, MySQL, SQLServer and S3 (Parquet, CSV, JSON and EXCEL).
- python
- aws
- pandas
- apache-arrow
- apache-parquet
- data-engineering
- +14 more
+3 stars
from 4,119 · score 1.39
203.pipelinedb / pipelinedb
High-performance time-series aggregation for PostgreSQL
- realtime
- stream-processing
- analytics
- sql
- push
- postgresql
- +3 more
+3 stars
from 2,663 · score 1.39
204.typelevel / fs2
Compositional, streaming I/O library for Scala
- scala
- stream
- streaming-computation
- fp
- functional-programming
+3 stars
from 2,453 · score 1.39
205.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
+3 stars
from 2,451 · score 1.39
206.Netflix / genie
Distributed Big Data Orchestration Service
- big-data
- bigdata
- orchestration
- configuration
- configuration-management
- java
- +7 more
+3 stars
from 1,765 · score 1.39
207.WallarooLabs / wally
Distributed Stream Processing
- stream-processing
- stream-processor
- stream-processing-engine
- pony-language
- python
- linux
- +4 more
+3 stars
from 1,483 · score 1.39
208.Netflix / mantis
A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications
+3 stars
from 1,471 · score 1.39
+3 stars
from 1,403 · score 1.39
210.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
+3 stars
from 1,315 · score 1.39
+3 stars
from 1,313 · score 1.39
212.spring-cloud / spring-cloud-stream
Framework for building Event-Driven Microservices
- microservices
- messaging
- event-driven-microservices
- stream-processing
- reactive
- cloud-native
+3 stars
from 1,069 · score 1.39
213.clj-commons / manifold
A compatibility layer for event-driven abstractions
- stream-processing
- future
- clojure
- async
- stream
+3 stars
from 1,053 · score 1.39
214.aelassas / wexflow
Workflow Automation Engine
- workflow-engine
- workflow
- cross-platform
- automation
- wexflow
- csharp
- +3 more
+3 stars
from 841 · score 1.39
215.MrPowers / chispa
PySpark test helper methods with beautiful error messages
+3 stars
from 774 · score 1.39
+3 stars
from 680 · score 1.39
217.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
+3 stars
from 593 · score 1.39
218.EchoVault / SugarDB
Embeddable and distributed in-memory alternative to Redis.
- cluster
- database
- distributed
- memory
- networking
- pubsub
- +13 more
+3 stars
from 536 · score 1.39
219.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
+3 stars
from 368 · score 1.39
220.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
+3 stars
from 279 · score 1.39
221.confluentinc / confluent-kafka-dotnet
Confluent's Apache Kafka .NET client
- kafka
- dotnet
- nuget
- c-sharp
- confluent
- kafka-client
- +1 more
+3 stars
from 276 · score 1.39
222.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
+3 stars
from 235 · score 1.39
223.nebulastream / nebulastream
Data management for the sensor-edge-cloud continuum
- bigdata
- streamprocessing
+3 stars
from 100 · score 1.39
224.Protocol-Lattice / GoEventBus
GoEventBus — high-performance event bus with a decision layer.
- golang
- library
- event-driven
- concurrency
- event-driven-architecture
- pubsub
- +8 more
+3 stars
from 72 · score 1.39
225.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
+3 stars
from 48 · score 1.39
226.riemann / riemann
A network event stream processing system, in Clojure.
- riemann
- events
- clojure
- monitoring
- logging
- metrics
- +1 more
+2 stars
from 4,267 · score 1.10
227.linkedin / databus
Source-agnostic distributed change data capture system
+2 stars
from 3,683 · score 1.10
228.ploomber / ploomberArchived
The fastest ⚡️ way to build data pipelines. Develop iteratively, deploy anywhere. ☁️
- workflow
- machine-learning
- data-science
- data-engineering
- mlops
- papermill
- +6 more
+2 stars
from 3,619 · score 1.10
229.krisleech / wisper
A micro library providing Ruby objects with Publish-Subscribe capabilities
- ruby
- events
- publish-subscribe
- pubsub
+2 stars
from 3,330 · score 1.10
230.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
+2 stars
from 2,891 · score 1.10
231.liftbridge-io / liftbridge
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
+2 stars
from 2,802 · score 1.10
232.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
+2 stars
from 2,268 · score 1.10
233.karafka / karafka
Ruby and Rails efficient Kafka processing framework
- karafka-framework
- kafka
- kafka-client
- kafka-clients
- kafka-producer
- kafka-consumer
- +14 more
+2 stars
from 2,251 · score 1.10
234.elastic / elasticsearch-hadoop
:elephant: Elasticsearch real-time search and analytics natively integrated with Hadoop
+2 stars
from 1,965 · score 1.10
235.faust-streaming / faust
Python Stream Processing. A Faust fork
- asyncio
- python-streaming
- kafka
- redis
- distributed-systems
+2 stars
from 1,888 · score 1.10
+2 stars
from 1,774 · score 1.10
+2 stars
from 1,693 · score 1.10
238.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
+2 stars
from 1,652 · score 1.10
239.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
+2 stars
from 1,595 · score 1.10
240.amphi-ai / amphi-etl
visual data prep powered by python
- data
- data-pipelines
- etl
- structured-data
- unstructured-data
- data-analysis
- +4 more
+2 stars
from 1,408 · score 1.10
241.graphframes / graphframes
GraphFrames is a package for Apache Spark which provides DataFrame-based Graphs
- apache-spark
- big-data
- connected-components
- dataframe
- dataframes
- graphs
- +8 more
+2 stars
from 1,210 · score 1.10
242.liyue201 / gostl
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
+2 stars
from 1,141 · score 1.10
243.allegro / hermes
Fast and reliable message broker built on top of Kafka.
+2 stars
from 871 · score 1.10
244.Cinchoo / ChoETL
ETL framework for .NET (Parser / Writer for CSV, Flat, Xml, JSON, Key-Value, Parquet, Yaml, Avro formatted files)
+2 stars
from 859 · score 1.10
245.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
+2 stars
from 743 · score 1.10
246.mrpowers-io / quinn
pyspark methods to enhance developer productivity 📣 👯 🎉
+2 stars
from 688 · score 1.10
247.ankurchavda / SparkLearning
A comprehensive Spark guide collated from multiple sources that can be referred to learn more about Spark or as an interview refresher.
+2 stars
from 687 · score 1.10
248.pingcap / tiflow
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
+2 stars
from 463 · score 1.10
+2 stars
from 446 · score 1.10
250.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
251.tinode / webapp
Tinode web chat using React
- chat
- chat-application
- chatapp
- react
- tinode
- instant-messaging
- +6 more
+2 stars
from 360 · score 1.10
252.strimzi / strimzi-kafka-bridge
An HTTP bridge for Apache Kafka®
+2 stars
from 343 · score 1.10
253.nilenso / goose
A powerful background job processing library for Clojure
+2 stars
from 313 · score 1.10
254.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
+2 stars
from 303 · score 1.10
255.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
256.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
257.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
258.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
+2 stars
from 155 · score 1.10
+2 stars
from 146 · score 1.10
260.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
261.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
+2 stars
from 129 · score 1.10
262.unit-io / unitdb
Time-series database and pub/sub messaging server for IoT and real-time devices, in Go: an embeddable storage engine with TTLs, wildcard topics and encryption, and a clustered server over gRPC, TCP and WebSocket with replication and rolling upgrades.
+2 stars
from 122 · score 1.10
263.drt-hub / drt
Reverse ETL for the code-first data stack
- bigquery
- cli
- data-engineering
- dbt
- duckdb
- etl
- +14 more
+2 stars
from 34 · score 1.10
264.Colin4k1024 / AetherisArchived
Execution runtime for intelligent agents with event-sourced, recoverable task orchestration.
- agent
- agents
- checkpointing
- dag
- engine
- event-sourcing
- +5 more
+2 stars
from 21 · score 1.10
265.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
266.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
+2 stars
from 11 · score 1.10
267.brunch / brunch
🍴 Web applications made easy. Since 2011.
+1 stars
from 6,753 · score 0.69
268.php-amqplib / php-amqplib
The most widely used PHP client for RabbitMQ
+1 stars
from 4,598 · score 0.69
+1 stars
from 4,382 · score 0.69
+1 stars
from 3,483 · score 0.69
271.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
272.alibaba / pipcook
Machine learning platform for Web developers
+1 stars
from 2,593 · score 0.69
273.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
+1 stars
from 2,487 · score 0.69
274.mara / mara-pipelines
A lightweight opinionated ETL framework, halfway between plain scripts and Apache Airflow
- etl
- data-integration
- python
- postgresql
- pipeline
- data
+1 stars
from 2,090 · score 0.69
+1 stars
from 1,784 · score 0.69
+1 stars
from 1,546 · score 0.69
277.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
+1 stars
from 1,534 · score 0.69
278.ruby-amqp / bunny
Bunny is a popular, easy to use, mature Ruby client for RabbitMQ
+1 stars
from 1,425 · score 0.69
279.lukasmartinelli / pgfutter
Import CSV and JSON into PostgreSQL the easy way
+1 stars
from 1,343 · score 0.69
280.killme2008 / Metamorphosis
A high available,high performance distributed messaging system.
+1 stars
from 1,327 · score 0.69
281.python-streamz / streamz
Real-time stream processing for python
- streaming-data
- python
- async
- real-time
+1 stars
from 1,305 · score 0.69
282.uber-archive / AthenaXArchived
SQL-based streaming analytics platform at scale
+1 stars
from 1,222 · score 0.69
283.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
284.jf-tech / omniparser
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
+1 stars
from 1,085 · score 0.69
285.apache / livy
Apache Livy is an open source REST interface for interacting with Apache Spark from anywhere.
+1 stars
from 960 · score 0.69
286.chat-sdk / chat-sdk-ios
Chat SDK iOS - Open Source Mobile Messenger
+1 stars
from 919 · score 0.69
287.doujiang24 / lua-resty-kafka
Lua kafka client driver for the Openresty based on the cosocket API
+1 stars
from 813 · score 0.69
288.gearpump / gearpump
Lightweight real-time big data streaming engine over Apache Pekko
- akka
- stream-processing
- bigdata
- scala
+1 stars
from 755 · score 0.69
289.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
+1 stars
from 741 · score 0.69
290.pardahlman / RawRabbit
A modern .NET framework for communication over RabbitMq
- rabbitmq
- dotnetcore
- message-bus
- async
+1 stars
from 740 · score 0.69
291.mongodb / mongo-spark
The MongoDB Spark Connector
+1 stars
from 728 · score 0.69
292.hstreamdb / hstream
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
- streaming
- database
- iot
- stream-processing
- haskell
- real-time
- +13 more
+1 stars
from 722 · score 0.69
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
+1 stars
from 719 · score 0.69
294.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
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
+1 stars
from 670 · score 0.69
296.jcuga / golongpoll
golang long polling library. Makes web pub-sub easy via HTTP long-poll servers and clients :smiley: :coffee: :computer:
- longpolling
- longpoll-requests
- longpoll-api
- longpoll
- go
- golang
- +5 more
+1 stars
from 665 · score 0.69
297.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
+1 stars
from 662 · score 0.69
298.uxlfoundation / oneDAL
oneAPI Data Analytics Library (oneDAL)
- onedal
- data-analysis
- oneapi
- machine-learning
- machine-learning-algorithms
- hacktoberfest
- +8 more
+1 stars
from 652 · score 0.69
299.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
+1 stars
from 627 · score 0.69
300.LGouellec / streamiz
.NET Stream Processing Library for Apache Kafka 🚀
- kafka-streams-dotnet
- kafka-streams
- kafka-streams-net
- kafka
- event-streaming
- streamiz
+1 stars
from 543 · score 0.69