我正在使用FlinkKafkaConsumer来使用来自kafka的数据？但我无法从收到的数据中得到最新的偏差 . 如何在flink中做到这一点？ . 有人能引导我吗？
您必须使用名为 KeyedDeserializationSchema 的自定义deserialziation架构来访问每条消息的偏移量 .
KeyedDeserializationSchema
deserialize() 方法有一个参数，框架会为您传递每条消息的偏移量 .
deserialize()
1 回答
您必须使用名为
KeyedDeserializationSchema的自定义deserialziation架构来访问每条消息的偏移量 .deserialize()方法有一个参数，框架会为您传递每条消息的偏移量 .