partitions into a new topic and
> >> migrate message index/logs and redirect pubs/subs to the new topic,
> >> during a traffic spike.
> >>
> >>> -Original Message-
> >>> From: Jun Rao [mailto:jun...@gmail.com]
> >>> Sent: Thursday,
mailto:jun...@gmail.com]
> Sent: Friday, May 17, 2013 8:52 AM
> To: users@kafka.apache.org
> Subject: Re: API to to query messages amount under one topic
>
> For monitoring, we have jmxs on the broker for both the message and the byte
> rate.
>
> Thanks,
>
> Jun
&
...@gmail.com]
Sent: Friday, May 17, 2013 8:52 AM
To: users@kafka.apache.org
Subject: Re: API to to query messages amount under one topic
For monitoring, we have jmxs on the broker for both the message and the byte
rate.
Thanks,
Jun
On Thu, May 16, 2013 at 10:04 PM, Rob Withers wrote:
> Immediat
> > > Any possibility for a queuedMessageCount(topic, partitionNumber)
> > protocol?
> > >
> > > thanks,
> > > rob
> > > ____________________
> > > From: Jun Rao [jun...@gmail.com]
> > > Sent: Wednesday, May 15, 2013 10
il.com]
> Sent: Thursday, May 16, 2013 10:00 PM
> To: users@kafka.apache.org
> Subject: Re: API to to query messages amount under one topic
>
> What do you plan to use this information for?
>
> Thanks,
>
> Jun
>
>
> On Thu, May 16, 2013 at 5:57 AM, Withers, Ro
@gmail.com]
> Sent: Wednesday, May 15, 2013 10:59 PM
> To: users@kafka.apache.org
> Subject: Re: API to to query messages amount under one topic
>
> In 0.8, you can get the earliest and the latest offset using the
> getOffsetBefore api. The difference btw the two gives th
Any possibility for a queuedMessageCount(topic, partitionNumber) protocol?
thanks,
rob
From: Jun Rao [jun...@gmail.com]
Sent: Wednesday, May 15, 2013 10:59 PM
To: users@kafka.apache.org
Subject: Re: API to to query messages amount under one topic
In 0.8
In 0.8, you can get the earliest and the latest offset using the
getOffsetBefore api. The difference btw the two gives the number of
messages on the broker.
Thanks,
Jun
On Wed, May 15, 2013 at 6:05 PM, Sining Ma wrote:
> Hi,
> Is there any APIs in kafka that I can use to query how many messag
+ 1!
A call through the Consumer Group, queuedMessageCount(topic,
partitionNumber), could query zookeeper (and add the local fetched queue) to
return this interesting piece of information. That is if we cannot already
do this :)
Thanks,
rob
> -Original Message-
> From: Sining Ma [mailto
