Repository Index

Logstash - transport and process your logs, events, or other data

• etl-framework
• streaming
• logging
• java

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.

• websocket
• redis
• real-time
• messaging

Building event-driven applications the easy way in Go.

• watermill
• event-driven
• event-sourcing
• sagas

The leader in Customer Data Infrastructure

• snowplow
• analytics
• data
• data-pipeline

🪽 An open, easy, fast, reliable and battery-efficient solution for real-time communications

• api
• web-api
• server-sent-events
• subscriptions

A network event stream processing system, in Clojure.

• riemann
• events
• clojure
• monitoring

A micro library providing Ruby objects with Publish-Subscribe capabilities

• ruby
• events
• publish-subscribe
• pubsub

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

Ruby and Rails efficient Kafka processing framework

• karafka-framework
• kafka
• kafka-client
• kafka-clients

: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

Home of Quamina, a fast pattern-matching library in Go

• event-driven
• go
• golang
• json

Messaging patterns for Backbone applications.

• backbone
• marionette
• radio
• pub-sub

Postgres change events (CDC) in Elixir [WAL]

• cdc
• change-data-capture
• elixir
• postgres

Modular .NET messaging for commands, queries, events, durable inbox and outbox processing, sagas, and broker transports.

• cqrs
• cqs
• csharp
• dotnet-core

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

Emissary is simple, yet 🗲FAST🗲 messaging library for decoupling messages (requests and events) and message handlers 🚀

• java
• jvm
• messaging
• requests

Stream database events from PostgreSQL to Kafka

• postgresql
• events
• stream
• kafka

☝️ go-graphql subscription over Kafka/Redis/NSQ example

• go
• graphql
• graphql-subscriptions
• kafka

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

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