This is not possible with the current high-level consumer without a restart, but the new consumer (under development) does have support for this.
On Wed, Mar 04, 2015 at 03:04:57PM -0500, Luiz Geovani Vier wrote: > 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
