flink读取kafka中数据时，如何获取当前的偏移量

在 Flink 中，可以使用 Kafka Consumer 的 `getCurrentOffsets()` 方法来获取当前的偏移量。该方法返回一个 `Map<TopicPartition, Long>` 对象，其中 `TopicPartition` 表示主题和分区的组合，`Long` 表示该主题和分区的当前偏移量。

以下是一个示例代码，展示如何使用 Kafka Consumer 的 `getCurrentOffsets()` 方法来获取当前的偏移量：

import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;
import org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema;
import org.apache.kafka.common.TopicPartition;

import java.util.Map;

public class KafkaOffsetExample {
    public static void main(String[] args) {
        // 读取 Kafka 数据流
        FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>("topic", new KafkaDeserializationSchema<String>() {
            @Override
            public boolean isEndOfStream(String s) {
                return false;
            }

            @Override
            public String deserialize(byte[] bytes) {
                return new String(bytes);
            }

            @Override
            public TypeInformation<String> getProducedType() {
                return TypeInformation.of(String.class);
            }
        }, KafkaConfig.getProperties());

        // 获取当前的偏移量
        Map<TopicPartition, Long> currentOffsets = kafkaConsumer.getCurrentOffsets();

        // 输出当前的偏移量
        for (Map.Entry<TopicPartition, Long> entry : currentOffsets.entrySet()) {
            System.out.println("Partition: " + entry.getKey() + ", Offset: " + entry.getValue());
        }
    }
}