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: almost 2 years ago
eventsgogolangkafkawatermill

Related projects:

RepositoryDescriptionStars
threedotslabs/watermill-firestoreA Firestore-based Pub/Sub system designed to work with event-driven applications0
threedotslabs/watermill-httpA Pub/Sub system for building event-driven applications with efficient message streams.28
threedotslabs/watermill-sqlA Pub/Sub system for event-driven applications that efficiently processes message streams between Postgres/MySQL databases72
threedotslabs/watermill-boltA Bolt-based Pub/Sub system for event-driven applications6
threedotslabs/watermill-ioA Pub/Sub messaging system designed to work with message streams in event-driven applications.8
threedotslabs/watermill-amqpA Pub/Sub system for event-driven applications using AMQP protocol55
threedotslabs/watermill-redisstreamA Redis Pub/Sub implementation for message streams in event-driven applications34
threedotslabs/watermill-googlecloudProvides a Pub/Sub system for event-driven applications on Google Cloud.20
threedotslabs/watermill-natsAn implementation of the NATS Pub/Sub messaging system for building event-driven applications with efficient message streams.53
threedotslabs/event-driven-exampleAn Event-Driven application example built in Go with Watermill library134
nmaquet/kasperA lightweight library for processing Kafka topics with idempotent at-least-once semantics439
threedotslabs/watermillA 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-kitTools and services for efficient management of Kafka topics and brokers488
xitonix/trubkaA command-line tool for interacting with Kafka clusters333
wintoncode/winton-kafka-streamsA Python implementation of Apache Kafka's Streams API for building stream processing applications311