There is a per-partition jmx (*-ConsumerLag) in the consumer that reports unconsumed messages per partition.
Thanks, Jun On Wed, May 28, 2014 at 8:13 AM, Рябков Алексей Николаевич < a.ryab...@ntc-vulkan.ru> wrote: > Hello! > > How can I get information about unfetched message per partition in topic? > I wish to use such information to create my custom > partitioner.class to balance messages between partitions > > With best regards, Aleksey Ryabkov > >
