101.frain-dev / convoy
The Cloud Native Webhooks Gateway
- webhooks
- convoy
- golang
- automation
- cli
- cloud
- +12 more
+51 stars
from 2,837 · score 3.95
Trending repositories
Ranked by Attention Score: stars gained over the last 90 complete days
101–200 of 426 by Attention Score · Aug 6, 2026 – Nov 3, 2026 (UTC)
102.cloudamqp / lavinmq
Ultra quick message queue and streaming server
- message-queue
- server
- amqp
- background-jobs
- job-queue
- message-broker
- +3 more
+51 stars
from 980 · score 3.95
103.timeplus-io / proton
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.
- clickhouse
- kakfa
- sql
- redpanda
- single-binary
- stream-processing
- +10 more
+50 stars
from 2,231 · score 3.93
104.mahmoud / boltons
🔩 Like builtins, but boltons. 250+ constructs, recipes, and snippets which extend (and rely on nothing but) the Python standard library. Nothing like Michael Bolton.
- python
- utilities
- cache
- data-structures
- statistics
- data-science
- +5 more
+48 stars
from 6,896 · score 3.89
105.softwaremill / elasticmq
In-memory message queue with an Amazon SQS-compatible interface. Runs stand-alone or embedded.
- scala
- sqs-interface
- elasticmq
- amazon-sqs
- aws
- aws-sqs
- +1 more
+48 stars
from 2,905 · score 3.89
106.MassTransit / MassTransit
Distributed Application Framework for .NET
+47 stars
from 7,766 · score 3.87
107.hazelcast / hazelcast
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.
- java
- hazelcast
- in-memory
- big-data
- scalability
- distributed
- +9 more
+47 stars
from 6,583 · score 3.87
108.thingsboard / thingsboard-gateway
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.
+45 stars
from 2,160 · score 3.83
109.OpenHFT / Chronicle-Queue
Micro second messaging that stores everything to disk
- chronicle
- queue
- java
- performance
- low-latency
- persistance
+44 stars
from 3,783 · score 3.81
110.mher / flower
Real-time monitor and web admin for Celery distributed task queue
- celery
- task-queue
- monitoring
- administration
- workers
- rabbitmq
- +3 more
+42 stars
from 7,197 · score 3.76
111.dotnetcore / CAP
Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
- kafka
- rabbitmq
- distributed-transactions
- outbox-pattern
- eventbus
- microservices
- +1 more
+41 stars
from 7,082 · score 3.74
112.absmach / magistrala
IoT Platform Framework
- golang
- iot-platform
- edge-computing
- distributed-systems
- iot-cloud
- iot-gateway
- +14 more
+40 stars
from 2,618 · score 3.71
113.dimitri / pgcopydb
Copy a Postgres database to a target Postgres server (pg_dump | pg_restore on steroids)
+40 stars
from 1,539 · score 3.71
114.vernemq / vernemq
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!
- mqtt
- m2m
- scalable
- broker
- erlang
- distributed
- +13 more
+39 stars
from 3,607 · score 3.69
115.fluvio-community / fluvio
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
- cloud-native
- streaming
- rust
- real-time
- serverless
- stateful
- +13 more
+38 stars
from 5,222 · score 3.66
116.projectnessie / nessie
Nessie: Transactional Catalog for Data Lakes with Git-like semantics
- data
- spark
- java
- iceberg
- aws-lambda
- git
+38 stars
from 1,488 · score 3.66
117.bytewax / bytewax
Python Stream Processing
- python
- stream-processing
- rust
- data-engineering
- data-processing
- data-science
- +3 more
+36 stars
from 2,034 · score 3.61
118.developit / mitt
🥊 Tiny 200 byte functional event emitter / pubsub.
- mitt
- event-handlers
- pubsub
- tiny
- event
- event-bus
- +2 more
+35 stars
from 11,869 · score 3.58
+35 stars
from 1,036 · score 3.58
120.meetfranz / franz
Franz is a free messaging app for services like WhatsApp, Slack, Messenger and many more.
+34 stars
from 4,695 · score 3.56
121.deepchecks / deepchecks
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.
- machine-learning
- ml
- model-validation
- data-validation
- mlops
- data-science
- +8 more
+33 stars
from 4,035 · score 3.53
122.profanity-im / profanity
Ncurses based XMPP client
- xmpp-client
- c
- xmpp
- chat
- ncurses
- decentralization
- +6 more
+33 stars
from 1,519 · score 3.53
123.polyaxon / polyaxon
AI Infra / AI Orchestration / AI Control Plane
+32 stars
from 3,715 · score 3.50
124.apache / kyuubi
Apache Kyuubi is a distributed and multi-tenant gateway to provide serverless SQL on data warehouses and lakehouses.
+32 stars
from 2,344 · score 3.50
125.snowplow / snowplow
The leader in Customer Data Infrastructure
- snowplow
- analytics
- data
- data-pipeline
- data-collection
- product-analytics
- +3 more
+31 stars
from 7,017 · score 3.47
126.Wisser / Jailer
Database Subsetting and Relational Data Browsing Tool.
+31 stars
from 3,185 · score 3.47
127.BrighterCommand / Brighter
A framework for building messaging apps with .NET and C#.
- command-processor
- command-dispatcher
- brighter
- asynchronously
- nuget-packages
- scale
- +11 more
+31 stars
from 2,459 · score 3.47
+31 stars
from 1,238 · score 3.47
129.kroxylicious / kroxylicious
Kroxylicious, the snappy open source proxy for Apache Kafka®
+31 stars
from 301 · score 3.47
130.estuary / flow
🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊
- change-data-capture
- data
- data-collection
- data-engineering
- data-integration
- data-pipeline
- +2 more
+30 stars
from 957 · score 3.43
131.thingsboard / tbmq
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.
+30 stars
from 746 · score 3.43
+29 stars
from 7,165 · score 3.40
133.apache / ignite
Apache Ignite
- distributed-sql-database
- iot
- osgi
- network-client
- ignite
- data-management-platform
- +9 more
+29 stars
from 5,061 · score 3.40
134.lf-edge / ekuiper
Lightweight data stream processing engine for IoT edge
+29 stars
from 1,718 · score 3.40
135.awslabs / deequ
Deequ is a library built on top of Apache Spark for defining "unit tests for data", which measure data quality in large datasets.
- dataquality
- spark
- unit-testing
- scala
+28 stars
from 3,629 · score 3.37
136.elixir-broadway / broadway
Concurrent and multi-stage data ingestion and data processing with Elixir
- elixir
- genstage
- data-ingestion
- data-processing
- concurrent
- broadway
+27 stars
from 2,665 · score 3.33
137.sfu-db / dataprep
Open-source low code data preparation library in python. Collect, clean and visualization your data in python with a few lines of code.
- dataprep
- data-science
- datapreparation
- dataconnector
- eda
- exploratory-data-analysis
- +7 more
+27 stars
from 2,243 · score 3.33
138.ekazaev / ChatLayout
ChatLayout is an alternative solution to MessageKit. It uses custom UICollectionViewLayout to provide you full control over the presentation as well as all the tools available in UICollectionView. It supports dynamic cells and supplementary view sizes.
- chat
- chat-application
- messaging
- messenger
- uicollectionviewlayout
- collectionview
- +7 more
+27 stars
from 1,035 · score 3.33
139.laravel / horizon
Dashboard and code-driven configuration for Laravel queues.
+26 stars
from 4,153 · score 3.30
140.celery / kombu
Messaging library for Python.
- celery
- messaging
- python
- message-queue
- kombu
- python-library
- +5 more
+26 stars
from 3,126 · score 3.30
141.Multiwoven / multiwoven
🔥🔥🔥 Open source Reverse ETL - alternative to hightouch and census.
- data-engineering
- reverse-etl
- data-pipeline
- data-activation
- etl
- react
- +14 more
+26 stars
from 1,658 · score 3.30
142.pmacct / pmacct
pmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].
- netflow
- ipfix
- sflow
- bgp
- bmp
- kafka
- +14 more
+26 stars
from 1,231 · score 3.30
143.Tochemey / goakt
[Go]Distributed Actor/Grain framework for Golang with goodies
- actor-model
- actors
- actorsystem
- golang
- golang-library
- distributed-systems
- +13 more
+26 stars
from 364 · score 3.30
144.apache / streampipes
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
- iot
- analytics
- edge
- stream-processing
- iiot
- self-service
- +6 more
+25 stars
from 731 · score 3.26
145.eventum-generator / eventum
Realistic synthetic events for testing, demos, and pipelines — streamed live or generated in bulk
- clickhouse
- data-engineering
- data-generation
- devops
- elasticsearch
- fake-data
- +12 more
+25 stars
from 46 · score 3.26
146.bloomberg / blazingmq
A modern high-performance open source message queuing system
+24 stars
from 3,197 · score 3.22
147.rebus-org / Rebus
:bus: Simple and lean service bus implementation for .NET
- rebus
- c-sharp
- service-bus
- messaging
- message-queue
- messaging-library
- +2 more
+24 stars
from 2,652 · score 3.22
148.Desbordante / desbordante-core
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.
- data-analytics
- data-cleaning
- data-cleansing
- data-engineering
- data-exploration
- data-mining
- +14 more
+24 stars
from 493 · score 3.22
149.edenhill / kcat
Generic command line non-JVM Apache Kafka producer and consumer
+23 stars
from 5,768 · score 3.18
150.moscajs / aedes
Barebone MQTT broker that can run on any stream server, the node way
+23 stars
from 1,957 · score 3.18
151.samber / ro
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
- event-driven
- generics
- go
- golang
- pipe
- pipeline
- +11 more
+23 stars
from 673 · score 3.18
152.numaproj / numaflow
Kubernetes-native platform to run massively parallel data/streaming jobs
- kubernetes
- stream-processing
- data-processing
- k8s
- pipeline
- map-reduce
- +1 more
+22 stars
from 2,815 · score 3.14
153.masslight / ottehr
Modular, Production-Ready, Open-Source EHR
- ehr
- electronic-health-record
- fhir
- health
- healthcare
- hipaa
- +10 more
+22 stars
from 321 · score 3.14
154.arkflow-rs / arkflow
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
- flow
- rust
- rust-lang
- stream
- sql
- datafusion
- +14 more
+21 stars
from 1,295 · score 3.09
155.boazsegev / iodine
iodine - HTTP / WebSockets Server for Ruby with Pub/Sub support
- ruby
- server
- pubsub
- sse
- clustering
- high-performance
- +5 more
+21 stars
from 969 · score 3.09
156.stn1slv / awesome-integration
A curated list of awesome system integration software and resources.
- esb
- bpm
- ipaas
- apimanagement
- etl
- mq
- +13 more
+21 stars
from 548 · score 3.09
+20 stars
from 2,442 · score 3.04
+20 stars
from 1,675 · score 3.04
+19 stars
from 3,352 · score 3.00
160.WeBankFinTech / DataSphereStudio
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.
+19 stars
from 3,256 · score 3.00
161.rabbitmq / rabbitmq-dotnet-client
RabbitMQ .NET client for .NET Standard 2.0+ and .NET 4.6.2+
- rabbitmq
- dotnet
- dotnet-core
- c-sharp
+19 stars
from 2,271 · score 3.00
162.apache / eventmesh
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
- esb
- event-driven
- event-mesh
- event-governance
- cloud-native
- serverless
- +11 more
+19 stars
from 1,740 · score 3.00
163.esl / MongooseIM
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.
- mongooseim
- erlang
- xmpp
- jabber
- messaging
- chat
- +1 more
+19 stars
from 1,740 · score 3.00
164.Aiven-Open / karapace
Karapace - Your Apache Kafka® essentials in one tool
- kafka
- schema-registry
- rest-proxy
+19 stars
from 622 · score 3.00
165.thomhurst / ModularPipelines
Write your pipelines in C# !
- build
- build-system
- build-tool
- build-tools
- csharp
- pipeline
- +6 more
+19 stars
from 540 · score 3.00
+18 stars
from 4,954 · score 2.94
167.zendesk / maxwell
Maxwell's daemon, a mysql-to-json kafka producer
+18 stars
from 4,248 · score 2.94
168.quixio / quix-streams
Python Streaming DataFrames for Kafka
+18 stars
from 1,564 · score 2.94
169.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
+18 stars
from 1,194 · score 2.94
170.tenzir / tenzir
Tenzir is the data pipeline engine for security teams.
- incident-response
- threathunting
- siem
- soc
- security
- dataops
- +9 more
+18 stars
from 752 · score 2.94
+17 stars
from 2,446 · score 2.89
172.ankane / pgsync
Sync data from one Postgres database to another
+16 stars
from 3,464 · score 2.83
173.piskvorky / smart_open
Utils for streaming large files (S3, HDFS, gzip, bz2...)
+16 stars
from 3,452 · score 2.83
174.ConduitIO / conduit
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
- go
- data-integration
- etl
- data-pipeline
- data-engineering
- data-stream
- +3 more
+16 stars
from 601 · score 2.83
175.luno / workflow
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 🚀
- eventdrivenarchitecture
- golang
- kafka
- reflex
- state-machine
- statemachine
- +10 more
+16 stars
from 248 · score 2.83
176.goptics / varmq
A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program
- concurrency
- go
- goroutine
- priority-queue
- queue
- worker
- +6 more
+16 stars
from 193 · score 2.83
177.FluidGroup / swiftui-messaging-ui
For SwiftUI apps - a primitive component to make Chat-UI with stable prepending - no scroll jumps when loading older messages.
+16 stars
from 73 · score 2.83
178.zeromq / netmq
A 100% native C# implementation of ZeroMQ for .NET
- zeromq
- netmq
- messaging
- dotnet
- dotnet-core
+15 stars
from 3,165 · score 2.77
179.confluentinc / schema-registry
Confluent Schema Registry for Kafka
- schema-registry
- kafka
- schema
- schemas
- avro
- avro-schema
- +6 more
+15 stars
from 2,456 · score 2.77
180.apache / inlong
Apache InLong - a one-stop, full-scenario integration framework for massive data
- inlong
- one-stop-service
- data-streaming
- event-streaming
- framework
- massive-data-integration
- +1 more
+15 stars
from 1,492 · score 2.77
181.confluentinc / confluent-kafka-dotnet
Confluent's Apache Kafka .NET client
- kafka
- dotnet
- nuget
- c-sharp
- confluent
- kafka-client
- +1 more
+15 stars
from 264 · score 2.77
182.yahoo / CMAK
CMAK is a tool for managing Apache Kafka clusters
+14 stars
from 11,904 · score 2.71
+14 stars
from 6,685 · score 2.71
184.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
+14 stars
from 4,108 · score 2.71
+14 stars
from 1,811 · score 2.71
186.pyjanitor-devs / pyjanitor
Clean APIs for data cleaning. Python implementation of R package Janitor
- pandas
- dataframe
- data
- cleaning-data
- data-engineering
- pydata
- +1 more
+14 stars
from 1,487 · score 2.71
187.2ndQuadrant / pglogical
Logical Replication extension for PostgreSQL 17, 16, 15, 14, 13, 12, 11, 10, 9.6, 9.5, 9.4 (Postgres), providing much faster replication than Slony, Bucardo or Londiste, as well as cross-version upgrades.
- postgresql
- replication
- logical-decoding
- database-replication
- subscription
- publish-subscribe
- +5 more
+14 stars
from 1,230 · score 2.71
188.apache / linkis
Apache Linkis builds a computation middleware layer to facilitate connection, governance and orchestration between the upper applications and the underlying data engines.
+13 stars
from 3,403 · score 2.64
189.typelevel / fs2
Compositional, streaming I/O library for Scala
- scala
- stream
- streaming-computation
- fp
- functional-programming
+13 stars
from 2,443 · score 2.64
+13 stars
from 1,393 · score 2.64
191.reductstore / reductstore
High-performance, time-indexed object storage for robotics and industrial IoT
- blob-storage
- storage-engine
- storage
- historian
- timeseries
- time-series
- +9 more
+13 stars
from 364 · score 2.64
192.nebulastream / nebulastream
Data management for the sensor-edge-cloud continuum
- bigdata
- streamprocessing
+13 stars
from 90 · score 2.64
193.nnnkkk7 / snowflake-emulator
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
+13 stars
from 44 · score 2.64
+12 stars
from 671 · score 2.56
195.capitalone / datacompy
Pandas, Polars, Spark, and Snowpark DataFrame comparison for humans and more!
- python
- pandas
- spark
- data
- data-science
- compare
- +8 more
+12 stars
from 653 · score 2.56
196.linkedin / databus
Source-agnostic distributed change data capture system
+11 stars
from 3,674 · score 2.48
197.chrislusf / gleam
Fast, efficient, and scalable distributed map/reduce system, DAG execution, in memory or on disk, written in pure Go, runs standalone or distributedly.
- distributed-computing
- map-reduce
- golang
- distributed-systems
+11 stars
from 3,558 · score 2.48
198.EasyNetQ / EasyNetQ
An easy to use .NET API for RabbitMQ
+11 stars
from 3,052 · score 2.48
199.reugn / go-streams
A lightweight stream processing library for Go
- stream-processing
- pipeline
- etl
- kafka
- data-stream
- kafka-streams
- +14 more
+11 stars
from 2,166 · score 2.48
200.faust-streaming / faust
Python Stream Processing. A Faust fork
- asyncio
- python-streaming
- kafka
- redis
- distributed-systems
+11 stars
from 1,879 · score 2.48