https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-HowdoIaccuratelygetoffsetsofmessagesforacertaintimestampusingOffsetRequest?
However, you will need to issue a TopicMetadataRequest first to discover the leaders for all the partitions and then issue the offset request. On Thu, Feb 05, 2015 at 11:54:00AM -0800, Bhavesh Mistry 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
