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

import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.common.serialization.SimpleStringSchema;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;

public class FlinkKafkaOffsetExample {

    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 设置重启策略
        env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, 10000));

        // 配置Kafka连接参数
        String kafkaBootstrapServers = "<kafka-bootstrap-servers>";
        String kafkaTopic = "<kafka-topic>";

        // 创建KafkaConsumer
        FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>(kafkaTopic, new SimpleStringSchema(), null);

        // 获取起始偏移量
        kafkaConsumer.setStartFromEarliest();

        // 将KafkaConsumer添加到Flink作业
        env.addSource(kafkaConsumer)
                .print();

        // 执行作业
        env.execute("Flink Kafka Offset Example");
    }
}