Public | Automated Build

Last pushed: 2 years ago
Short Description
golang based kafka/zookeeper offset checker
Full Description

Monitor Kafka Consumer Partition Offsets in Zookeeper

Simple golang based (kazoo-go and sarama) application to monitor Kafka offsets stored in Zookeeper, and calculate lag based on current Kafka partition sizes. Output is modeled after the official


go install


For current execution flags see kazoo-offsets -h

In general if you're using CLI flags the pattern is:

kazoo-offsets -zookeeper $(ZK_HOST):2181 -group-id $(KAFKA_GROUP_ID) -topic $(KAFKA_TOPIC)

If you want the values to update I highly recommend using watch

watch -n 5 kazoo-offsets -zookeeper $(ZK_HOST):2181 -group-id $(KAFKA_GROUP_ID) -topic $(KAFKA_TOPIC)
Docker Pull Command
Source Repository