Hi, I found in 0.9,
def commitOffsets(offsetsToCommit: java.util.Map[TopicAndPartition, OffsetAndMetadata], retryOnFailure: Boolean) is added to ZookeeperConsumerConnector. If I want to read data backwards or forwards, can I use this API to commit new offset and then read data from new offset? This api has same effect as Seek in KafkaConsumer? In 0.8.1.1, there is no such api. If we don't I think I can implement this feature by simply rewriting partition consumer offset on zk, right?