如何获取kafka主题分区的最后/结束偏移量？

问题描述

新消费者也很复杂。

//assign the topic consumer.assign();

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

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

解决方法

我正在kafka使用Java
编写使用者。我想保持消息的实时性，因此，如果有太多消息在等待使用，例如1000条或更多，我应该放弃未使用的消息，并从最后一个偏移量开始使用。

对于此问题，我尝试比较主题的最后提交的偏移量和主题的结束偏移量（仅1个分区），如果这两个偏移量之间的差大于某个值，则将主题的最后提交的偏移量设置为下一个偏移量，这样我就可以放弃那些多余的消息。

现在我的问题是如何获得主题的最终补偿，有人说我可以使用旧的使用者，但是它太复杂了，新使用者是否具有此功能？