Matthias created FLINK-19397:
--------------------------------
Summary: Offering error handling for the SerializationSchema analogous to DeserializationSchema
Key: FLINK-19397
URL:
https://issues.apache.org/jira/browse/FLINK-19397 Project: Flink
Issue Type: New Feature
Components: Connectors / Common
Reporter: Matthias
Yuval raised the issue about missing error handling when serializing objects into Kafka in this [ML thread|
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Ignoring-invalid-values-in-KafkaSerializationSchema-td38299.html].
[FLIP-124|
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148645988] already addressed this issue for the {{DeserializationSchema}}. We could introduce the same solution for {{SerializationSchema}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
