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
