如何打印 Flink 已开始读取的 Kafka 主题的每个分区的起始偏移量？

【问题标题】：How can I print starting offset of each partition of Kafka topic from which Flink has started reading?如何打印 Flink 已开始读取的 Kafka 主题的每个分区的起始偏移量？
【发布时间】：2020-08-05 13:46:49
【问题描述】：

我想打印 Flink 开始读取的 Kafka 主题的每个分区的起始偏移量？

【问题讨论】：

标签： apache-kafka apache-flink flink-streaming

【解决方案1】：

如果您使用KafkaDeserializationSchema 处理您的FlinkKafkaConsumer 的反序列化，则deserialize 方法将传递一个ConsumerRecord，其中包括分区和偏移量。您可以在第一次调用该方法时打印或记录。

【讨论】：