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)

Reply via email to