Hello,

I'm using the high level consumer with auto-commit disabled and a
single thread per consumer, in order to consume messages in batches.
In case of failures on the database, I'd like to stop processing,
rollback and restart from the last commited offset.
Is there a way to receive the messages since the last commit again,
without reconnecting? (something like a reset on KafkaStream or
ConsumerIterator)

Thanks,
-Geovani

Reply via email to