1.nats-io / nats-server
High-Performance server for NATS.io, the cloud and edge native messaging system.
- go
- golang
- messaging
- message-bus
- message-queue
- cloud-native
- +9 more
+659 stars
from 20,335 · score 6.49
Trending repositories
Ranked by Attention Score: stars gained over the last 90 complete days
76 repositories by Attention Score · Aug 6, 2026 – Nov 3, 2026 (UTC)
2.centrifugal / centrifugo
Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably, socket.io, Phoenix.PubSub, SignalR. Set up once and forever.
+385 stars
from 10,561 · score 5.96
3.openimsdk / open-im-server
IM Chat OpenClaw
+244 stars
from 16,508 · score 5.50
4.bruin-data / ingestr
ingestr is a CLI tool to copy data between any databases with a single command seamlessly.
- bigquery
- copy-database
- data-ingestion
- data-integration
- data-pipeline
- duckdb
- +4 more
+219 stars
from 3,820 · score 5.39
5.tinode / chat
Instant messaging platform. Backend in Go. Clients: Swift iOS, Java Android, JS webapp, scriptable command line; chatbots
- chat
- chat-application
- chatapp
- go
- golang
- instant-messaging
- +14 more
+157 stars
from 13,391 · score 5.06
6.bruin-data / bruin
Build data pipelines with SQL and Python, ingest data from different sources, add quality checks, and build end-to-end flows.
- analytics
- bigquery
- data-modeling
- data-pipelines
- python
- snowflake
- +5 more
+149 stars
from 1,650 · score 5.01
7.ThreeDotsLabs / watermill
Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
- events
- stream-processing
- +7 more
+142 stars
from 9,797 · score 4.96
8.nats-io / nats.go
Golang client for NATS, the cloud native messaging system.
- go
- golang
- nats
- microservices
- microservices-architecture
- pub-sub
- +3 more
+108 stars
from 6,689 · score 4.69
9.treeverse / lakeFS
lakeFS - Data version control for your data lake | Git for data
- data-engineering
- data-versioning
- go
- object-storage
- data-lake
- aws-s3
- +13 more
+107 stars
from 5,468 · score 4.68
10.turbot / steampipe
Zero-ETL, infinite possibilities. Live query APIs, code & more with SQL. No DB required.
- steampipe
- postgresql
- postgresql-fdw
- cloud
- security
- aws
- +14 more
+104 stars
from 7,890 · score 4.65
11.PeerDB-io / peerdb
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
- etl
- sql
- bigquery
- cloud-native
- distributed-systems
- kafka
- +10 more
+98 stars
from 3,215 · score 4.60
12.cloudquery / cloudquery
Data pipelines for cloud config and security data. Build cloud asset inventory, CSPM, FinOps, and vulnerability management solutions. Extract from AWS, Azure, GCP, and 70+ cloud and SaaS sources.
+84 stars
from 6,465 · score 4.44
13.redpanda-data / connect
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
- logs
- stream-processor
- +11 more
+83 stars
from 8,710 · score 4.43
14.dunglas / mercure
🪽 An open, easy, fast, reliable and battery-efficient solution for real-time communications
- api
- web-api
- server-sent-events
- subscriptions
- golang
- hypermedia
- +10 more
+72 stars
from 5,285 · score 4.29
+64 stars
from 12,459 · score 4.17
16.nsqio / nsq
A realtime distributed messaging platform
+62 stars
from 25,712 · score 4.14
17.emirpasic / gods
GoDS (Go Data Structures) - Sets, Lists, Stacks, Maps, Trees, Queues, and much more
- go
- golang
- data-structure
- map
- tree
- set
- +10 more
+62 stars
from 17,394 · score 4.14
18.rudderlabs / rudder-server
Privacy and Security focused Segment-alternative, in Golang and React
- privacy
- warehouse-management
- data-warehouse
- customer-data
- customer-data-pipeline
- customer-data-platform
- +14 more
+59 stars
from 4,456 · score 4.09
19.mochi-mqtt / server
The fully compliant, embeddable high-performance Go MQTT v5 server for IoT, smarthome, and pubsub
+56 stars
from 1,904 · score 4.04
20.frain-dev / convoy
The Cloud Native Webhooks Gateway
- webhooks
- convoy
- golang
- automation
- cli
- cloud
- +12 more
+51 stars
from 2,837 · score 3.95
21.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
22.lf-edge / ekuiper
Lightweight data stream processing engine for IoT edge
+29 stars
from 1,718 · score 3.40
23.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
24.wind-c / comqtt
A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
- golang
- mqtt
- iot
- cluster
- distributed
- golang-library
- +9 more
+23 stars
from 1,162 · score 3.18
25.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
+18 stars
from 4,954 · score 2.94
27.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
28.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
29.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
30.nnnkkk7 / snowflake-emulator
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
+13 stars
from 44 · score 2.64
31.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
32.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
33.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
34.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
35.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
36.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
37.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
38.gammazero / deque
Fast ring-buffer deque (double-ended queue)
- deque
- queue
- ring-buffer
- circular-buffer
- circular-queue
+9 stars
from 781 · score 2.30
39.nanomsg / mangos
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
+9 stars
from 753 · score 2.30
40.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
41.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
42.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
43.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
44.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
45.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
46.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
47.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
48.pingcap / tiflow
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
+4 stars
from 461 · score 1.61
49.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
50.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
51.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
52.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
53.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
54.Breeze0806 / go-etl
go-etl is a toolset for data extraction, transformation and loading.
- etl
- mysql
- go
- postgresql
- greenplum
- csv
- +5 more
+3 stars
from 189 · score 1.39
55.rulego / streamsql
Lightweight SQL-based stream processing engine for IoT edge.
+3 stars
from 61 · score 1.39
+2 stars
from 1,980 · score 1.10
57.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
58.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
60.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
61.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
62.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
63.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
64.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
65.nats-io / nats-streaming-serverArchived
NATS Streaming System Server
+1 stars
from 2,521 · score 0.69
66.lukasmartinelli / pgfutter
Import CSV and JSON into PostgreSQL the easy way
+1 stars
from 1,343 · score 0.69
67.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
68.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
69.xitonix / trubka
A CLI tool for Kafka
+1 stars
from 336 · score 0.69
70.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
+1 stars
from 224 · score 0.69
72.edwingeng / deque
A highly optimized double-ended queue
+1 stars
from 203 · score 0.69
73.embano1 / memlog
A Kafka log inspired in-memory and append-only data structure
+1 stars
from 142 · score 0.69
74.capillariesio / capillaries
Distributed batch data processing framework
- cassandra
- rabbitmq
- go
- batch-processing
- dag
- distributed-computing
- +5 more
+1 stars
from 73 · score 0.69
75.leozz37 / hare
🐇 CLI tool for websockets and Go package
+1 stars
from 54 · score 0.69
76.vinod-morya / fibersse
Production-grade Server-Sent Events (SSE) for Fiber v3. Event coalescing, priority lanes, topic wildcards, adaptive throttling, built-in auth, Prometheus metrics, graceful drain.
- event-streaming
- fasthttp
- fiber
- gofiber
- golang
- pub-sub
- +4 more
+1 stars
from 2 · score 0.69