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
