我使用新的api创建了一个kafka消费者(http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaconsumer.html)当前，使用者正在从最小偏移量开始读取主题中的消息。我想重写它，从最新的偏移量读取。关于如何做到这一点有什么建议吗？
2fjabf4q1#
一旦开始读取给定使用者组的消息，就需要使用seektoend（）方法显式地将使用者强制到它所跟随的分区的末尾。对于尚未阅读任何消息的使用者组，可以使用auto.offset.reset=largest属性告诉使用者在何处阅读其第一条消息。
bhmjp9jg2#
尝试设置 auto.offset.reset = largest ，尽管这应该是默认设置。
auto.offset.reset = largest
2条答案
按热度按时间2fjabf4q1#
一旦开始读取给定使用者组的消息，就需要使用seektoend（）方法显式地将使用者强制到它所跟随的分区的末尾。对于尚未阅读任何消息的使用者组，可以使用auto.offset.reset=largest属性告诉使用者在何处阅读其第一条消息。
bhmjp9jg2#
尝试设置
auto.offset.reset = largest，尽管这应该是默认设置。