Как получить последнее смещение для всех разделов темы?

Question

Мне нужно получать последнее смещение для всех разделов темы каждые N секунд (для целей кэширования). Что API я должен использовать для этого? Я думаю, мне нужен самый надежный и быстрый способ.

Я знаю два подхода:

1) Первый :

//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() является лучшим подходом.

Первый подход требует фактического назначения темы, что звучит так, как будто вам не нужно.