Eno Thereska created KAFKA-5157: ----------------------------------- Summary: Options for handling corrupt data during deserialization Key: KAFKA-5157 URL: https://issues.apache.org/jira/browse/KAFKA-5157 Project: Kafka Issue Type: Sub-task Components: streams Reporter: Eno Thereska
When there is a bad formatted data in the source topics, deserialization will throw a runtime exception all the way to the users. And since deserialization happens before it was ever processed at the beginning of the topology, today there is no ways to handle such errors on the user-app level. We should consider allowing users to handle such "poison pills" in a customizable way. -- This message was sent by Atlassian JIRA (v6.3.15#6346)