Kafka服务器是否有有关由于保留设置导致消费者丢失某些过期偏移量的日志记录？

Kafka服务器在没有覆盖消费者组保留期设置的情况下，将自动删除过期的偏移量。 如果消费者在保留期结束之前没有进行消费，则它将丢失已过期的偏移量，并不会记录日志。 如果您想手动记录这些丢失的偏移量，可以在消费者代码中添加相应的日志记录逻辑，如下所示：

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        // 处理消费记录
    }
    commitOffsets(); // 提交消费偏移量
    checkLostOffsets(); // 检查丢失的偏移量并记录日志
}

private void checkLostOffsets() {
    List<TopicPartition> topicPartitions = new ArrayList<>(consumer.assignment());
    Map<TopicPartition, Long> endOffsets = consumer.endOffsets(topicPartitions);

    for (TopicPartition partition : topicPartitions) {
        long committedOffset = consumer.committed(partition).offset();

        if (committedOffset < endOffsets.get(partition)) {
            // some offsets are missing, log the missing offsets.
            log.error("Offsets are missing for partition {}: {} - {}",
                    partition,
                    committedOffset + 1,
                    endOffsets.get(partition));
        }
    }
}