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)