There is no way to implement the below flow
- Read batch messages from Kafka.
- Process all the messages.
- If all messages processing succesful - Commit the offset
- If any of the message processing fails - Do not commit the offset and read the same batch again and try to process the messages and if successful commit the offset.
There is no way to implement the below flow