watermill-kafka

Pub/Sub engine

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

Kafka Pub/Sub for the Watermill project.

GitHub

61 stars
5 watching
40 forks
Language: Go
last commit: 24 days 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 69
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 33
threedotslabs/watermill-googlecloud Provides a Pub/Sub system for event-driven applications on Google Cloud. 19
threedotslabs/watermill-nats An implementation of the NATS Pub/Sub messaging system for building event-driven applications with efficient message streams. 52
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,749
datadog/kafka-kit Tools and services for efficient management of Kafka topics and brokers 489
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 stream processing applications 313