kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joel Koshy <jjkosh...@gmail.com>
Subject Re: Get Latest Offset for Specific Topic for All Partition
Date Thu, 05 Feb 2015 20:15:25 GMT
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


Mime
View raw message