Kafka library in Go

An aggregated records producer for Amazon Kinesis

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

Worker pool implementation

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

Frizzle for Apache Kafka

Rest Api based kafka event producer that supports multiple encoding types including Avro, Json, MessagePack, String & Bytes.

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

POC Event-Driven Architecture (EDA) in Hedge Fund, using golang nats client

Package bigbuff implements a one-many ordered queue producer-consumer pattern + utilities.

Pubs/Subs model with AWS sqs

nsq 生产者负载均衡，支持轮询、随机、平滑权重 让数据平均写入nsqd 减少数据丢失风险及提高机器使用率。

Rabbit client connection with auto reconnect

Embeddable, Lightweight, Sharded In-App Messaging in Go

Frizzle for AWS Kinesis

Subspace is a fast, memory only signal broker, using atomic network operations, with no further dependencies.