有没有办法从Java API中的特定偏移量开始消费kafka主题？

import org.apache.kafka.clients.consumer.*;
import org.apache.kafka.common.*;

import java.util.*;

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

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

        TopicPartition partition = new TopicPartition("my-topic", 0);
        consumer.assign(Collections.singletonList(partition));

        long offset = 1000; // 指定起始偏移量
        consumer.seek(partition, offset);

        while (true) {
            ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
            for (ConsumerRecord<String, String> record : records) {
                System.out.println("Received message: " + record.value());
            }
        }
    }
}