Hi Yassine, there's an ongoing discussion about the issue in this JIRA: https://issues.apache.org/jira/browse/FLINK-3679. Emitting null is not an option. There are workarounds to the issue, but I think they are all not nice.
On Thu, Aug 25, 2016 at 8:05 PM, Yassine Marzougui <yassmar...@gmail.com> wrote: > Hi all, > > Is there a way to handle hafka deserialization exceptions, when a JSON > message is malformed for example? > > I thought about extending the DeserializationSchema to emit a null or any > other value, but that may cause an NPE when using a subsequent > TimestampExtractor. > The other solution would be to do the serialization in a subsequent > flatMap operator but it would be more convient to do it directly in the > consumer to make the timestamps extraction (with the new kafka consumer > timestamp extractor) easier. > > Any suggestions? > > Best, > Yassine >
