consumer-group

Kafka Web UI

A AI-Driven, Distributed and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.

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.

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

CLI for Apache Kafka Management -

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.

openmrs - mysql - debezium - kafka - spark - scala

Examples to understand the features provided by Kafka

Kafka consumer for golang with partition-ordered concurrent processing and event handling

kafka consumer-group client

Simple Custom Producer Consumer group demonstrating message passing in Kafka

How to use shared subscriptions (subscription groups) with Emitter

Restore and migrate consumer offsets tool for Kafka clusters

Kafka consumer tool to set and get offsets for consumer group and also list consumer members

Kafka-inspired lightweight pub/sub message queue built from scratch in Python — topic partitioning, consumer groups, async streaming, dead letter queue. For understanding the flow, objects and how Kafka works.

Kafka consumer group autoscaler

practice files of kafka

A parcel-tracking pipeline used as a Kafka fan-out lab: one consumer group plus a Postgres ledger, because per-waybill ACK progress cannot be written into a commit offset. Sender leases and epoch fencing included, all reproducible with docker compose.