Skip to content

Latest commit

 

History

History
27 lines (15 loc) · 501 Bytes

README.md

File metadata and controls

27 lines (15 loc) · 501 Bytes

kafka-lag-monitor

This is an app which monitors kafka offsets and log size on (consumergroup, topic) and provides lag information

compile:

mvn install

sample command:

java -jar target/kafka-lag-monitor

optional arg: --kafkaHost <hostName>, default is localhost:9092

Rest API :

A simple Rest API provides lag information on localhost:8090/topics/{topic-name}/offset

credits:

This code is mostly derived from https://github.com/srotya/kafka-lag-monitor