Repository navigation
Need ability to seek to the beginning of a partition #191
Description
We need the option to read from the beginning of a partition. Something along the lines of https://stackoverflow.com/questions/49723182/kafka-consumer-seektobeginning but the parallel consumer does not expose seekToBeginning() or assignment(). Is it possible to expose these or provide an overall wrapper for seekToBeginning()?
Blocked by:
Activity
astubbs commentedon May 17, 2022
This should be achievable from the following workaround:
rrva commentedon May 22, 2022
Antony Stubbs (@astubbs) I can't figure out how to implement this workaround. Please provide a working example.
astubbs commentedon Jul 5, 2022
FYI this is being implemented here: https://github.com/astubbs/parallel-consumer/tree/features/consumer-interface
astubbs commentedon Jul 12, 2022
You can try out the consumer interface branch now if you like - it works, and has been used in some experimental tests in other branches.
johnbyrnejb commentedon Jul 7, 2023
Closing Issue