我刚接触kafka,我知道我们可以在主题创建上给出delete.retention.ms,所有符合这个标准的消息都会被删除。
我想知道是否有一种方法可以给出每条消息的标准?或者也许有什么办法可以达到这个目标呢?
发布于 2018-08-10 22:46:43
由于Kafka消息是有序日志,因此不可能将消息从日志中间移除。因此,我不相信你所要求的是可能的。
https://stackoverflow.com/questions/51787814
相似问题