Hi everyone, After writing quite a few Kafka Streams applications, me and my colleagues just created KIP-1033 to introduce a new Exception Handler in Kafka Streams to simplify error handling. This feature would allow defining an exception handler to automatically catch exceptions occurring during the processing of a message.
KIP link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1033%3A+Add+Kafka+Streams+exception+handler+for+exceptions+occuring+during+processing Feedbacks and suggestions are welcome, Cheers, Damien, Sebastien and Loic