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?

Reply via email to