在jsondeserializat中获取错误ionschema:jsondeserializationschema cannot 解析为类型
DataStream<ObjectNode> messageStream = env.addSource(
new FlinkKafkaConsumer09<>("test2"
, new**JSONDeserializationSchema()**,properties));
messageStream.rebalance().map(new MapFunction<ObjectNode, String>() {
private static final long serialVersionUID = -6867736771747690202L;
@Override
public String map(ObjectNode value) throws Exception {
return "Kafka and Flink says: " + value.get("key").asText();
}
}).print();
1条答案
按热度按时间rqqzpn5f1#
@不,flink 1.8中删除了jsondeserializationschema()。
在连接kafka获取json数据时,我也遇到了类似的问题。您可以在下面的链接中找到不推荐的和后来删除的jsondeserializationschema的替代方法:
flink中是否不推荐使用jsondeserializationschema()?
我希望有帮助:)!!