使用高级API从特定偏移量开始读取kafka消息

我希望我没有犯错，但是我记得在Kafka文档中它提到使用高级API不能从特定的偏移量开始读取消息，但是有人提到它会发生变化。

现在是否可以使用高级API从特定分区和特定偏移量读取消息？请给我一个例子，怎么做？

我正在使用kafka 0.8.1.1。

提前致谢。

您可以使用kafka 0.9做到这一点：

http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html

public void seek(TopicPartition partition, long offset)

覆盖使用者将在下一次轮询（超时）时使用的获取偏移量。如果对同一分区多次调用此API，则最新的偏移量将用于下一个poll（）。请注意，如果在使用过程中随意使用此API来重置获取偏移量，则可能会丢失数据