我需要每N秒获得所有主题分区的最后一个偏移量(用于缓存目的)。我应该使用什么API?我想,我需要最可靠,最快捷的方式。
我知道两种方法:
1)首先……
打电话给 consumer.endOffsets() 是更好的方法。
consumer.endOffsets()
第一种方法需要实际分配主题,这听起来像你不需要。