如何获取所有主题分区的最后一个偏移量？

Question

我需要每 N 秒获取所有主题分区的最后偏移量（用于缓存目的）。我应该使用什么API？我想，我需要最可靠、最快捷的方式。

我知道两种方法：

1)First one:

//assign the topic
consumer.assign();

//seek to end of the topic
consumer.seekToEnd();

//the position is the latest offset
consumer.position();

2) 第二个：

consumer.endOffsets()

Answer 1

致电consumer.endOffsets() 是更好的方法。

第一种方法需要实际分配主题，听起来你不需要。