Kafka的日志整理指针是什么？

Kafka 中的日志整理指针是一种特殊的索引机制，用于支持日志的压缩和清理。当使用日志整理功能时，Kafka 会压缩具有相同键值的消息，只保留最新的一条消息。这样可以在不删除任何消息的情况下，有效地减少日志的大小。

在Kafka中，日志压缩索引将被保存在特殊的“.index”文件中。可以使用Kafka提供的API来查询压缩指针的信息，例如：

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(configProperties);
TopicPartition tp = new TopicPartition("my-topic",0);
consumer.assign(Collections.singletonList(tp));
consumer.seekToBeginning(Collections.singletonList(tp));
List<ConsumerRecord<String, String>> records = new ArrayList<>();
try {
    while (true) {
        ConsumerRecords<String, String> consumerRecords = consumer.poll(Duration.ofMillis(1000));
        if (consumerRecords.count()==0) {
            break;
        }
        for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {
            records.add(consumerRecord);
        }
    }
} catch(Exception e) {
    // handle exception
}

// 获取压缩指针信息
OffsetAndMetadata logStartOffset = consumer.committed(tp);
long logEndOffset = consumer.endOffsets(Collections.singletonList(tp)).get(tp);