Hi,
I'd suggest to implement your own custom deserialization schema for example
by extending JSONKeyValueDeserializationSchema.
Then you can implement whatever logic you need to handle incorrectly
formatted messages.
Best, Fabian
Am Mi., 10. Juli 2019 um 04:29 Uhr schrieb Zhechao Ma <
mazhechaom
I'm trying to catch exception throws by the kafka source, and I've got the
answer that exception in source or sink cannot be caught.
Thanks
Haibo Sun 于2019年7月8日周一 下午3:54写道：
> Hi, Zhechao
>
> Usually, if you can, share your full exception stack and where you are
> trying to capture exceptions
Hello,
I'm using flinkKafkaConsumer to read message from a kafka topic with
JSONKeyValueDeserializationSchema. When the message is json formatted,
everything works fine, but it throws NullPointerException when processing a
message is not json formatted. I try to catch the exception but cannot do
t
