flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zhechao Ma <mazhechaomaill...@gmail.com>
Subject Cannot catch exception throws by kafka consumer with JSONKeyValueDeserializationSchema
Date Mon, 08 Jul 2019 06:11:22 GMT
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
that.

Can anyone give out some tips?

flink: 1.5
flink-kafka: 1.5
kafka-clients: 0.10.1.2_2.11
flink-json:

-- 
Thanks
Zhechao Ma

Mime
View raw message