Home

uGroup - Kafka Consumer Group Monitor

uGroup monitors Kafka consumer groups by reading the __consumer_offsets topic and calculating/reporting consumer lag metrics.

Features

• Real-time consumer lag monitoring - Track offset lag across all partitions
• Prometheus metrics export - Native integration with Prometheus via Micrometer
• Flexible filtering - Monitor all consumers, specific groups via YAML, or regex patterns
• Blocklist support - Exclude noisy or test consumer groups
• REST API - Query lag data programmatically
• Docker support - Easy deployment with Docker Compose
• Extensible architecture - Plug in custom implementations for metrics, caching, and cluster discovery

Quick Start

Using Docker Compose

cd docker
docker-compose up -d

This starts Kafka, Zookeeper, and uGroup. Access the API at http://localhost:8080.

Using Gradle

# Build
./gradlew build

# Run with local Kafka
KAFKA_BOOTSTRAP_SERVERS=localhost:9092 ./gradlew bootRun

Documentation

• Configuration
• API Endpoints
• Watchlist Configuration
• Blocklist Configuration
• Extending uGroup
• Metrics
• Building
• Architecture
• Contributing

License

Apache License 2.0 - see LICENSE for details.