如何在kafka中按键标记删除消息



我需要标记由键删除指定的消息,但是我知道删除消息的唯一脚本是 kafka-delete-records.sh。但是,它可以与偏移量的偏移和删除一起工作,然后在偏移范围之前,这不适合我。是否可以使用指定的偏移量或键删除

kafka并不是真正设计的。这是一个不变的事件日志。根据您的记录,您可能会记录一个相反的操作,如果您想否定它,则先前记录的操作。

这是有关如何使用压实主题和墓碑(null)消息查看删除消息的更多信息:https://www.confluent.io/blog/handling-gdpr-log-forget/

最新更新