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
