Ranked by Attention Score: stars gained over the last 180 complete days
101–200 of 391 by Attention Score · May 8, 2026 – Nov 3, 2026 (UTC)
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
The fully compliant, embeddable high-performance Go MQTT v5 server for IoT, smarthome, and pubsub
Real-time monitor and web admin for Celery distributed task queue
The Cloud Native Webhooks Gateway
A cluster computing framework for processing large-scale geospatial data
Micro second messaging that stores everything to disk
The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.
Copy a Postgres database to a target Postgres server (pg_dump | pg_restore on steroids)
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
Open-source IoT Gateway - integrates devices connected to legacy and third-party systems with ThingsBoard IoT Platform using Modbus, CAN bus, BACnet, BLE, OPC-UA, MQTT, ODBC and REST protocols.
🥊 Tiny 200 byte functional event emitter / pubsub.
Real-time decision features without streaming infra. Turn live events into product reflexes — no Kafka, no Flink, no feature store.
Python Stream Processing
High-performance, time-indexed object storage for robotics and industrial IoT
A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases. The VerneMQ mission is active & the project maintained. Thank you for your support!
🔩 Like builtins, but boltons. 250+ constructs, recipes, and snippets which extend (and rely on nothing but) the Python standard library. Nothing like Michael Bolton.
IoT Platform Framework
Nessie: Transactional Catalog for Data Lakes with Git-like semantics
Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
Database Subsetting and Relational Data Browsing Tool.
Healthcare data infrastructure for next generation care delivery.
A framework for building messaging apps with .NET and C#.
🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊
Franz is a free messaging app for services like WhatsApp, Slack, Messenger and many more.
Deepchecks: Tests for Continuous Validation of ML Models & Data. Deepchecks is a holistic open-source solution for all of your AI & ML validation needs, enabling to thoroughly test your data and models from research to production.
Dashboard and code-driven configuration for Laravel queues.
Lightweight data stream processing engine for IoT edge
visual data prep powered by python
Apache Kyuubi is a distributed and multi-tenant gateway to provide serverless SQL on data warehouses and lakehouses.
Ncurses based XMPP client
The swiss army knife of healthcare integration.
A modern high-performance open source message queuing system
Deequ is a library built on top of Apache Spark for defining "unit tests for data", which measure data quality in large datasets.
The leader in Customer Data Infrastructure
Write your pipelines in C# !
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
Generic command line non-JVM Apache Kafka producer and consumer
The ultimate distributed MQTT broker. Handles 100M+ connections and 10M msg/sec with ease. Built on Kafka to provide industrial-grade persistence and eliminate data loss.
Concurrent and multi-stage data ingestion and data processing with Elixir
Messaging library for Python.
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
[Go]Distributed Actor/Grain framework for Golang with goodies
:bus: Simple and lean service bus implementation for .NET
Kroxylicious, the snappy open source proxy for Apache Kafka®
AI Infra / AI Orchestration / AI Control Plane
Apache Ignite
Confluent Schema Registry for Kafka
🔥🔥🔥 Open source Reverse ETL - alternative to hightouch and census.
A curated list of awesome system integration software and resources.
A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
Modular, Production-Ready, Open-Source EHR
For SwiftUI apps - a primitive component to make Chat-UI with stable prepending - no scroll jumps when loading older messages.
Open-source low code data preparation library in python. Collect, clean and visualization your data in python with a few lines of code.
GraphFrames is a package for Apache Spark which provides DataFrame-based Graphs
DataSphereStudio is a one stop data application development& management portal, covering scenarios including data exchange, desensitization/cleansing, analysis/mining, quality measurement, visualization, and task scheduling.
Barebone MQTT broker that can run on any stream server, the node way
Python Streaming DataFrames for Kafka
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Desbordante is a high-performance data profiler that is capable of discovering many different patterns in data using various algorithms. It also allows to run data cleaning scenarios using these algorithms. Desbordante has a console version and an easy-to-use web application.
CMAK is a tool for managing Apache Kafka clusters
A 100% native C# implementation of ZeroMQ for .NET
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
Maxwell's daemon, a mysql-to-json kafka producer
Sync data from one Postgres database to another
Tenzir is the data pipeline engine for security teams.
The type-safe, event-driven workflow orchestration library that scales with your business. Build robust, distributed workflows in Go with compile-time safety, automatic retries, and horizontal scaling out of the box. Integrate with your existing tech stack using adapters 🚀
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).
Karapace - Your Apache Kafka® essentials in one tool
MongooseIM is Erlang Solutions' robust, scalable and efficient XMPP server, aimed at large installations. Specifically designed for enterprise purposes, it is fault-tolerant and can utilise the resources of multiple clustered machines.
Pandas, Polars, Spark, and Snowpark DataFrame comparison for humans and more!
Utils for streaming large files (S3, HDFS, gzip, bz2...)
Ruby and Rails efficient Kafka processing framework
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
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
Realistic synthetic events for testing, demos, and pipelines — streamed live or generated in bulk
RabbitMQ .NET client for .NET Standard 2.0+ and .NET 4.6.2+
Clean APIs for data cleaning. Python implementation of R package Janitor
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.
Apache Linkis builds a computation middleware layer to facilitate connection, governance and orchestration between the upper applications and the underlying data engines.
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
Python Stream Processing. A Faust fork
Confluent's Apache Kafka .NET client
Apache InLong - a one-stop, full-scenario integration framework for massive data
Fast ring-buffer deque (double-ended queue)
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program
An easy to use .NET API for RabbitMQ
The idiomatic asyncio MQTT client