Hi, Is there a way to commit consuming of events only if I had ran code successfully?
In other words, In this code while (it.hasNext()) { /** Iterator on kafka High lever consumer*/ try { MessageAndMetadata<Message> current = it.next(); dealWithEvent(current); }catch (Exception e){ } } What should I do, If I want events that ended up in the catch, will be read again by another consumer or the same consumer until the they don't throw exception. Thanks, Guy