Flink 数据流中的反序列化

Question

在这里我写了一个字符串给Kafka主题，flink消耗了这个主题。反序列化是通过使用SimpleStringSchema完成的。当我需要使用整数值时，应该使用什么反序列化方法而不是SimpleStringschema???

DataStream<String> messageStream = env.addSource(new FlinkKafkaConsumer09<String>("test2", new SimpleStringSchema(), properties));

Answer 1

你需要定义自己的序列化模式

https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializationSchema.java#L32

或者将其保留为字符串，然后将流映射到所需的类型