I have implemented application checkpointing mechanism , in which the consumer before consuming messages from the partition , check the offset from where it needs to start reading from and then ResetPartitionOffset is called to set the offset to the required one. But after doing that it is not able to start reading immediately from that offset.If this is not possible what is the point of having the function.
Or is it that there is some way to do that with the library.
dim
commented
5 years ago
I have implemented application checkpointing mechanism , in which the consumer before consuming messages from the partition , check the offset from where it needs to start reading from and then ResetPartitionOffset is called to set the offset to the required one. But after doing that it is not able to start reading immediately from that offset.If this is not possible what is the point of having the function.
Or is it that there is some way to do that with the library.