Hi,

quick question: From the KIP it doesn't quite makes sense to me how that fits with caching. With caching the consumer record might not be at all related to some processor throwing while processing.

would it not make more sense to get the ProcessorName + object object for processing and statestore or topic name + byte[] byte[] for serializers? maybe passing in the used serdes?

Best Jan



On 25.05.2017 11:47, Eno Thereska wrote:
Hi there,

I’ve added a KIP on improving exception handling in streams:
KIP-161: streams record processing exception handlers. 
https://cwiki.apache.org/confluence/display/KAFKA/KIP-161%3A+streams+record+processing+exception+handlers
 
<https://cwiki.apache.org/confluence/display/KAFKA/KIP-161:+streams+record+processing+exception+handlers>

Discussion and feedback is welcome, thank you.
Eno

Reply via email to