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

DDD+CQRS+Event-sourcing examples using EventFlow following CQRS-ES architecture. It is configured with RabbitMQ, MongoDB(Snapshot store), PostgreSQL(Read store), EventStore(GES). It's targeted to .Net Core 2.2 and include docker compose file.

• eventflow
• cqrs
• cqrs-es-architecture
• ges

Event-Sourcing and Domain-Driven Design with F# and EventStore

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

Domain Driven Design, CQRS, & Event Sourcing Example using GetEventStore, CommonDomain, NServiceBus, Entity Framework, SQL Server, SignalR

Elixir Adapter for EventStore

• eventstore
• elixir-lang
• cqrs
• erlang

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

• java
• jvm
• messaging
• requests

Functional domain models with event sourcing in Elixir

A simplified (in memory) example of Event Sourcing implementation for banking domain.

• event-sourcing
• ddd
• ddd-sample

Realistic synthetic events for testing, demos, and pipelines — streamed live or generated in bulk

• clickhouse
• data-engineering
• data-generation
• devops

Stream database events from PostgreSQL to Kafka

• postgresql
• events
• stream
• kafka