Kafka library in Go

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

KMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requirements.

redisqueue provides a producer and consumer of a queue that uses Redis streams

Golang AMQP reliable connection, publisher, consumer.

Worker pool implementation

How to write CDC test using Pact in Go? 🤔

RocketMQ client for go supportting producer and consumer.

Using NATS Jetstream as queue manager to replace RabbitMQ, etc.

Fault tolerant Pub/Sub library for RabbitMQ

The magic message bus

Notification Hub for openware stack

Frizzle for Apache Kafka

make your kafka integration easy with kafka-go (supports Kafka v0.8 - v2.3)

Kafka consumer that read data (multiply topics could be specified to )from kafka and write them to disk split by topic, date

TCP traffic analyzer that can capture requests from clients to Kafka Broker, parse them and expose stats like client IPs as Prometheus metrics.

KafkaOffsetTool is a lightweight tool for Kafka offset operation and maintenance

Consumer for NSQ which forwards Traefik access logs to InfluxDB

High abstraction wrapper for Golang Rabbit MQ Client

Pikaq makes writing your own high performance message-based services fun and type safe.