Kafka主题的保留期是如何工作的?

eyh26e7m  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(381)

在主题t1中说。
保留期设置为2天。
第一天收到100条信息
第二天收到100条信息
总计=200条消息
会在第三天,全部200条信息被清理干净吗?
或者只有前100条消息,还有100条消息?

tjvv9vkg

tjvv9vkg1#

前100条消息将被标记为删除。
然而 log.segment.bytes 以及 log.segment.delete.delay.ms 在删除日志时也起作用
考虑以下情况:
案例1: log.retention.ms = 60000, log.segment.delete.delay.ms=60000, log.segment.bytes = 10000 当日志段大小被破坏时。在本例中,kafka仅当最大时间戳通过log.retention.ms(即60秒)时才标记要删除的段。
案例2:
如果 log.segment.bytes 是大的,直到 log.retention.ms Kafka将等待 log.segment.delete.delay.ms 删除日志

相关问题