We use Burrow <https://github.com/linkedin/Burrow>. There are rest endpoints you can use to get offsets and manually calculate lag, but if you are focused on alerting, I'd use it's consumer statuses as they are a bit smarter than a simple lag calculation.
On Wed, Sep 2, 2015 at 4:08 AM shahab <shahab.mok...@gmail.com> wrote: > Hi, > > I wonder how we can monitor lag (difference between consumer offset and log > ) when "kafka" is set as offset.storage? because the "kafka-run-class.sh > kafka.tools.ConsumerOffsetChecker ... " does work only when zookeeper is > used as storage manager. > > best, > /Shahab >
