watermill-kafka

Pub/Sub engine

A Kafka-based Pub/Sub system for event-driven applications

Kafka Pub/Sub for the Watermill project.

GitHub

63 stars
5 watching
41 forks
Language: Go
last commit: about 2 months ago
eventsgogolangkafkawatermill

Related projects:

Repository Description Stars
threedotslabs/watermill-firestore A Firestore-based Pub/Sub system designed to work with event-driven applications 0
threedotslabs/watermill-http A Pub/Sub system for building event-driven applications with efficient message streams. 28
threedotslabs/watermill-sql A Pub/Sub system for event-driven applications that efficiently processes message streams between Postgres/MySQL databases 72
threedotslabs/watermill-bolt A Bolt-based Pub/Sub system for event-driven applications 6
threedotslabs/watermill-io A Pub/Sub messaging system designed to work with message streams in event-driven applications. 8
threedotslabs/watermill-amqp A Pub/Sub system for event-driven applications using AMQP protocol 55
threedotslabs/watermill-redisstream A Redis Pub/Sub implementation for message streams in event-driven applications 34
threedotslabs/watermill-googlecloud Provides a Pub/Sub system for event-driven applications on Google Cloud. 20
threedotslabs/watermill-nats An implementation of the NATS Pub/Sub messaging system for building event-driven applications with efficient message streams. 53
threedotslabs/event-driven-example An Event-Driven application example built in Go with Watermill library 134
nmaquet/kasper A lightweight library for processing Kafka topics with idempotent at-least-once semantics 439
threedotslabs/watermill A library for building event-driven applications in Go, making it easy to work with message streams and enabling various architectures such as CQRS and event sourcing. 7,907
datadog/kafka-kit Tools and services for efficient management of Kafka topics and brokers 488
xitonix/trubka A command-line tool for interacting with Kafka clusters 333
wintoncode/winton-kafka-streams A Python implementation of Apache Kafka's Streams API for building stream processing applications 311