Kafka带有压缩和删除的主题不会删除键”

在Kafka中，当一个主题使用压缩和删除策略时，删除操作只会标记记录被删除，并不会在日志中立即删除记录。这可能会导致删除的键仍然存在于主题中，影响客户端的数据读取。为了解决这个问题，您可以将数据从主题中删除并将其重新写入。代码示例如下：

KafkaProducer<String, String> producer = new KafkaProducer<>(props);

// 将键与空值一起写入主题，以删除该键
ProducerRecord<String, String> record = new ProducerRecord<>("topic-name", "key", null);
producer.send(record).get();

// 再次向主题写入记录，以确保键已被删除
record = new ProducerRecord<>("topic-name", "key", "value");
producer.send(record).get();