You can take a look at the consumer offset checker tool, which reads the consumed offsets in ZK and the data size in broker to compute the lag. You can re-use that logic to implement the partitioner.
Guozhang 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 > > -- -- Guozhang
