Take a look at ConsumerOffsetChecker. It does just that: print the offset and lag for each consumer and partition.
You can either use that class directly, or use it as a guideline for your implementation On Wed, Oct 1, 2014 at 2:10 AM, Shlomi Hazan <shl...@viber.com> wrote: > Hi, > How can I programmatically get the number of items in a topic, pending for > consumption? > If no programmatic way is avail, what other method is available? > Shlomi
