从 Kafka 的主题中删除一条消息

Removing one message from a topic in Kafka

我是 Kafka 的新手,我有一个问题。如果我知道主题、偏移量和分区,我可以只从主题中删除一条消息吗?如果没有,还有其他选择吗?

即使您知道它的分区和偏移量,也无法从 Kafka 主题中删除单个消息。

请记住,Kafka 不是 key/value 存储,而主题是代表数据流的仅附加(!)日志。

如果您正在寻找删除单个消息的替代方法,您可以

  1. 让您的消费者客户忽略该消息

  2. 启用日志压缩并发送逻辑删除消息

  3. 编写一个简单的作业 (KafkaStreams) 来使用数据、过滤掉一条消息并将所有消息生成到一个新主题。