如何获取kafka主题分区的末尾偏移量？

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.TopicPartition;
import java.util.*;

public class KafkaOffsetExample {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "kafka-server1:9092,kafka-server2:9092");
        props.put("group.id", "my-consumer-group");
        props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

        List<TopicPartition> partitions = new ArrayList<>();
        partitions.add(new TopicPartition("my-topic", 0));
        partitions.add(new TopicPartition("my-topic", 1));
        // 添加更多的主题分区...

        consumer.assign(partitions);

        Map<TopicPartition, Long> endOffsets = consumer.endOffsets(partitions);
        for (TopicPartition partition : endOffsets.keySet()) {
            long endOffset = endOffsets.get(partition);
            System.out.println("Partition " + partition.partition() + ": " + endOffset);
        }

        consumer.close();
    }
}