Kafka记录没有被删除。

要解决“Kafka记录没有被删除”的问题，可以使用以下代码示例：

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

public class KafkaRecordDeletionExample {
    public static void main(String[] args) {
        String topicName = "your-topic-name";
        String groupId = "your-group-id";
        String bootstrapServers = "your-bootstrap-servers";

        // 创建Kafka消费者配置
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");

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

        // 订阅主题
        consumer.subscribe(Collections.singletonList(topicName));

        try {
            // 消费消息
            ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(1000));
            for (ConsumerRecord<String, String> record : records) {
                // 在这里处理消息逻辑，例如删除记录的代码
                // ...
                // 删除记录的代码示例：
                consumer.commitSync(Collections.singletonMap(new TopicPartition(record.topic(), record.partition()), new OffsetAndMetadata(record.offset() + 1)));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            consumer.close();
        }
    }
}

请注意，以上示例代码使用了KafkaConsumer类来消费消息，并通过commitSync方法来手动提交消费者的偏移量。通过在处理完消息后手动提交偏移量，可以确保消息已被正确处理和删除。