Hi Gwen, This JMX stats is good for calculate injection rate per partition. I do not have to depend on ZK to figuring out who is leader what is latest offset.
One quick question, what is Size # ? is it # of bytes particular partition has on disk ? Unfortunately, MBean description is very limited and does not help much(it is "Information on the management interface of the MBean"). It is gauge that is all I can tell . 1189855393 LogEndOffset 1165330350 Size 1176813232 LogStartOffset Thanks for your help !! Thanks, Bhaevsh Thanks, Bhavesh On Thu, Feb 5, 2015 at 12:55 PM, Gwen Shapira <gshap...@cloudera.com> wrote: > You can use the metrics Kafka publishes. I think the relevant metrics are: > Log.LogEndOffset > Log.LogStartOffset > Log.size > > > Gwen > > On Thu, Feb 5, 2015 at 11:54 AM, Bhavesh Mistry > <mistry.p.bhav...@gmail.com> wrote: > > HI All, > > > > I just need to get the latest offset # for topic (not for consumer > group). > > Which API to get this info ? > > > > My use case is to analyze the data injection rate to each of partition > is > > uniform or not (close). For this, I am planing to dump the latest offset > > into graphite for each partition and look at derivative over time. > > > > Thanks, > > > > Bhavesh >
