Hi everyone, This is a Streams KIP to add a new DeserializationHandlerResponse, "SUSPEND", that suspends the failing Task but continues to process other Tasks normally.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-990%3A+Capability+to+SUSPEND+Tasks+on+DeserializationException I'm not yet completely convinced that this is practical, as I suspect it might be abusing the SUSPENDED Task.State for something it was not designed for. The intent is to pause an active Task *without* re-assigning it to another instance, which causes cascading failures when the FAIL DeserializationHandlerResponse is used. Let me know what you think! Regards, Nick
