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

Question

我正在使用 FlinkKafkaConsumer 来消费来自 kafka 的数据？但我无法从收到的数据中获得最新的偏移量。如何在 flink 中做到这一点？。有人可以指导我吗？

Answer 1

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

deserialize() 方法有一个参数，框架会将每条消息的偏移量传递给您。