Can we do dynamic rewind in setting offset to earlier point on the fly?

[hothero]

We used to do something like

doRewind(topicAndTime); // reset offset based on the topic and partition
kafkaConsumer.poll(getPollTimeMillis());

however, based on the parallel-consumer's architecture diagram, there is a work state management. We're not sure if we can directly manage that. Could you please advice? Is there any way that we can update the offset on the fly while the consumers are still consuming messages?

Note: our consumer has self-protection mechanism to process "new" data only, so no concern to us to do so in real time.

[hothero]

#782 covered