使用Flink时Kafka中json数据不清楚时如何反序列化

Question

我想通过 Flink 计算 Kafka 中的数据，但问题是 Kafka 中的 JASON 数据可能会发生变化。

像这样：

{"data":{"template":25,"name":"name"}}

或这个：

{"data"{"type":"type1","props":"props","strem":"stream1"}

而且我无法提前知道这个 JSON 中包含了多少数据。所以在使用 Flink 时有一个问题：

streamExecutionEnvironment.addSource(new FlinkKafkaConsumer010<KafkaEvent>("flink", new KafkaEventSchema(),

            kafkaProps))

            .flatMap(new KafkaEventToRow()).returns(getReturnType());

那么Json数据这样的时候如何定义pojo类型和mapFuncation呢？