我希望我没有犯错，但是我记得在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来重置获取偏移量，则可能会丢失数据
| 归档时间： |
|
| 查看次数： |
17097 次 |
| 最近记录： |