如何从 FlinkKafkaConsumer 获取最新的消息偏移量?

Question

我正在使用 FlinkKafkaConsumer 来消费来自 kafka 的数据？但我无法从收到的数据中获得最新的偏移量。如何在眨眼中做到这一点？.谁能指导我？

Answer 1

您必须使用名为KeyedDeserializationSchema的自定义反序列化架构来访问每条消息的偏移量。

deserialize()方法有一个参数，框架在其中传递每条消息的偏移量。