我已经使用新的API (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)创建了一个kafka消费者
当前消费者正在读取从最小偏移量开始的来自主题的消息。我想重写这一点，以便从最近的偏移量读取。关于如何做到这一点，有什么建议吗?
一旦开始读取给定消费者组的消息，就需要使用seekToEnd()方法显式地强制消费者到它所遵循的分区的末尾。对于尚未读取任何消息的消费者组，您可以使用auto.offset。Reset =最大属性，用于告诉使用者在哪里读取第一条消息。
尝试设置auto.offset.reset = largest，尽管这应该是默认设置