我使用新API创建了一个kafka使用者（http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html）
目前，消费者正在阅读从最小偏移开始读取主题的消息 . 我想覆盖它来读取最新的偏移量 . 有关如何做到这一点的任何指示？
我使用新API创建了一个kafka使用者（http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html）
目前，消费者正在阅读从最小偏移开始读取主题的消息 . 我想覆盖它来读取最新的偏移量 . 有关如何做到这一点的任何指示？
2 回答
一旦开始阅读给定使用者组的消息，您将需要使用seekToEnd（）方法显式强制使用者访问它所遵循的分区的末尾 . 对于尚未读取任何消息的使用者组，您可以使用auto.offset.reset = largest属性告诉使用者在何处阅读其第一条消息 .
尝试设置
auto.offset.reset = largest，尽管这应该是默认设置 .