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
