kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: mBean to monitor message per partitions in topic
Date Wed, 28 May 2014 16:52:19 GMT
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.


On Wed, May 28, 2014 at 8:13 AM, Рябков Алексей Николаевич <
a.ryabkov@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

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message