在主题t1中说。保留期设置为2天。第一天收到100条信息第二天收到100条信息总计=200条消息会在第三天,全部200条信息被清理干净吗?或者只有前100条消息,还有100条消息?
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 删除日志
log.segment.bytes
log.segment.delete.delay.ms
log.retention.ms = 60000, log.segment.delete.delay.ms=60000, log.segment.bytes = 10000
log.retention.ms
1条答案
按热度按时间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
删除日志