Handling exceptions in Kafka streams is similar question but the accepted answer only talks about the productionException. How to handle the exceptions occurring during the processing and thereby how to control the manually offset committing.
2 Answers
You need to handle them manually, ie, use own try-catch blocks and react to them accordingly.
You may find the usage of this library helpful Libraries for error handling in Kafka Streams it offers various wrappers and a DLQ handling. Using it myself to grab exception while processing messages in stream processors. Only gap I‘ve seen is when you‘d like handle cases across multiple operations in a topology.
Related