MarkPartitionOffset has no effect

[lkzz]

Hi @bsm
In my program ,we want read messages on partition0 from the position:offset0,but there is no effect below:
MarkPartitionOffset(my_test_topic,partition0,offset0,"")

Or is there a way to achieve such requirements？

Looking forward to your reply,thanks.

[flisky]

There are cmLoop to commit offsets periodically. Or you can call CommitOffsets directly.

[lkzz]

In fact, the partition consumer is already running,when you commit an old offset,the partition will not read from that offset position only if the partition consumer recreated.

[dim]

There is no sensible way to "rewind" to a previous offset in sarama-cluster. Given your requirements, I would probably use Sarama directly.