小编Raj*_*war的帖子

我是 Flink 新手，正在做与以下链接非常相​​似的事情。

下沉 kafka 流时看不到消息，并且在 flink 1.2 中看不到打印消息

我还尝试添加 JSONDeserializationSchema() 作为没有密钥的 Kafka 输入 JSON 消息的反序列化器。

但我发现 JSONDeserializationSchema() 不存在。

如果我做错了什么，请告诉我。