我想通過 Flink 計算 Kafka 中的數(shù)據(jù)，但問題是 Kafka 中的 JASON 數(shù)據(jù)可能會發(fā)生變化。像這樣：{"data":{"template":25,"name":"name"}}或這個：{"data"{"type":"type1","props":"props","strem":"stream1"}而且我無法提前知道這個 JSON 中包含了多少數(shù)據(jù)。所以在使用 Flink 時有一個問題：streamExecutionEnvironment.addSource(new FlinkKafkaConsumer010<KafkaEvent>("flink", new KafkaEventSchema(),            kafkaProps))            .flatMap(new KafkaEventToRow()).returns(getReturnType());那么Json數(shù)據(jù)這樣的時候如何定義pojo類型和mapFuncation呢？