Kafka获取最近的offset

 

有两个函数

kafka.api.OffsetRequest.LatestTime

OffsetFetchRequest

0.8.2以前都是从zookeeper中读offset，从0.8.2之后从kafka中读取offset