Ilya created KAFKA-17994: ---------------------------- Summary: Runtime exceptions are not handled when deserializing kafka stream record Key: KAFKA-17994 URL: https://issues.apache.org/jira/browse/KAFKA-17994 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 3.9.0 Reporter: Ilya
When we got a PR to upgrade kafka clients 3.8.1 -> 3.9.0, we saw some failing tests. They were relating to using a DeserializationExceptionHandler with 'log and continue' strategy, however on newest version the stream was just crashing when Jackson was trying to deserialize a faulty json and this handler was not invoked. In this [KIP-1033|https://cwiki.apache.org/confluence/display/KAFKA/KIP-1033%3A+Add+Kafka+Streams+exception+handler+for+exceptions+occurring+during+processing], specifically in this PR [https://github.com/apache/kafka/pull/16745/files#diff-77791b213bb41d1df63a23860f1faf4394dfbd7d6c4ed9cd021950d82c31c24f] a change was introduced to catch only RuntimeException type and handle them in the handler. However, all the Jackson exceptions inherit Exception type, not RuntimeException. So with this change all the Jackson exceptions (or any checked exceptions) would not be passed to the DeserializationExceptionHandler like it was before. -- This message was sent by Atlassian Jira (v8.20.10#820010)