请叫一个flink和kafka集成问题,如果用这个API(FlinkKafkaConsumer010(List<String> topics, DeserializationSchema<T> deserializer, Properties props))同时读多个topic,用什么Schema,能在收到的消息中得到这个消息时来自哪个topic?
同问,为什么FlinkKafkaConsumer010 不能使用SimpleStringSchema楼主有新的 DeserializationSchema 实现方式么?
赞0
踩0