Kafka是删除记录还是只移动偏移量？

Kafka默认情况下是保留所有消息，包括被消费的消息，从而保留消费者的偏移量。这样在消费者端重新启动时，可以从上一次消费的位置继续消费。如果需要删除消息，可以设置合适的保留策略（retention policy），或者手动删除记录。

代码示例：

// 配置保留策略 Properties props = new Properties(); props.put("retention.ms", "604800000");// 一周 props.put("cleanup.policy", "delete");// 删除策略

// 手动删除记录 KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props, new StringDeserializer(), new StringDeserializer()); consumer.subscribe(Collections.singletonList("mytopic")); while (true) { ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord<String, String> record : records) { // 消费消息 // ... // 手动删除消息 consumer.commitSync(Collections.singletonMap(new TopicPartition(record.topic(), record.partition()), new OffsetAndMetadata(record.offset() + 1))); } }