从kafka数据帧获取最大、最小偏移量

import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.TopicPartition;

import java.util.Arrays;
import java.util.Properties;

public class KafkaOffsetExample {
    public static void main(String[] args) {
        // Kafka配置
        Properties props = new Properties();
        props.put("bootstrap.servers", "kafka服务器地址");
        props.put("group.id", "消费者组ID");
        props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

        // 创建Kafka消费者
        Consumer<String, String> consumer = new KafkaConsumer<>(props);

        // 订阅主题
        consumer.subscribe(Arrays.asList("要订阅的主题"));

        // 获取分区
        TopicPartition partition = new TopicPartition("要获取偏移量的主题", 分区号);

        // 获取最大和最小偏移量
        long minOffset = consumer.beginningOffsets(Arrays.asList(partition)).get(partition);
        long maxOffset = consumer.endOffsets(Arrays.asList(partition)).get(partition);

        System.out.println("最小偏移量：" + minOffset);
        System.out.println("最大偏移量：" + maxOffset);

        // 关闭消费者
        consumer.close();
    }
}