从 Kafka 的主题中删除一条消息
Removing one message from a topic in Kafka
我是 Kafka 的新手,我有一个问题。如果我知道主题、偏移量和分区,我可以只从主题中删除一条消息吗?如果没有,还有其他选择吗?
即使您知道它的分区和偏移量,也无法从 Kafka 主题中删除单个消息。
请记住,Kafka 不是 key/value 存储,而主题是代表数据流的仅附加(!)日志。
如果您正在寻找删除单个消息的替代方法,您可以
让您的消费者客户忽略该消息
启用日志压缩并发送逻辑删除消息
编写一个简单的作业 (KafkaStreams) 来使用数据、过滤掉一条消息并将所有消息生成到一个新主题。
我是 Kafka 的新手,我有一个问题。如果我知道主题、偏移量和分区,我可以只从主题中删除一条消息吗?如果没有,还有其他选择吗?
即使您知道它的分区和偏移量,也无法从 Kafka 主题中删除单个消息。
请记住,Kafka 不是 key/value 存储,而主题是代表数据流的仅附加(!)日志。
如果您正在寻找删除单个消息的替代方法,您可以
让您的消费者客户忽略该消息
启用日志压缩并发送逻辑删除消息
编写一个简单的作业 (KafkaStreams) 来使用数据、过滤掉一条消息并将所有消息生成到一个新主题。