consumer-groups

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

QueenMQ is a new generation distributed message broker, able to sustain millions of messages per second.

One CLI and TUI for Kafka and RabbitMQ: peek, publish, debug consumer groups, dry-run routing and administer clusters from the terminal.

Parallel consuming the same data with different Consumer Groups

Kafka's model of topics, partitions, offsets and consumer groups inside Laravel. Pure PHP, no broker required.

Kafka consumer group offsets side by side: read, align, replay, clean up, with dry run, backups and restore. One Go binary.

Kafka-like distributed event streaming platform built in Java with Netty, consumer groups, leader-follower replication, and Spring Boot admin API

Real-time Kafka clickstream pipeline with sessionization, consumer groups, PostgreSQL, and Docker.

Learn and Implement Simple Kafka broker using Spring Boot to publish and consume message

Turn your filesystem into a message broker. Exchanges, persistent streams, consumer groups, priority queues, dead letters, retries, metrics — everything you expect from RabbitMQ, Kafka & NATS, in a single zero-dependency PHP 8.4 library.

Streaming fraud scoring end-to-end — durable event log with consumer groups + at-least-once delivery (crash recovery proven: 0/800 lost), online windowed features, ~10k events/s, precision 82%/recall 92%, PSI drift alerting

Pooled Redis for long-running PHP — coroutine-safe connections, prefixed stores, and typed handles for hashes, lists and streams with consumer groups.

Realtime, animated, read-only visualizer for Redis Streams: streams, consumer groups, lag and pending entries in motion.

Malachi: Distributed log storage system (🚧 In Development).

A small event-streaming system in Go with partitioned logs, consumer groups, persistent offsets, and a monitoring dashboard.

Preview what a Kafka consumer-group offset reset would do: reprocess/skip counts per partition, without committing anything.

Audit Redis Streams consumer groups via the Pending Entries List.

Event-driven telemetry pipeline in Go: partitioned log (Redpanda), idempotent consumers, Postgres sink, DLQ with replay, and SSE fan-out to a live map

Interactive Next.js dashboard over a real 6-broker Apache Kafka cluster — see Leader election, 6-broker Apache Kafka 클러스터의 Leader 재선출 · Fan-out · Replay · 백프레셔를 실시간으로 보여주는 Next.js 시각화 데모 fan-out, replay, and backpressure happen live.