Первые 100 сообщений будут помечены для удаления.
Однако log.segment.bytes
и log.segment.delete.delay.ms
также играют роль в удалении журналов
Рассмотрим следующий сценарий ios :
Случай 1:
log.retention.ms = 60000, log.segment.delete.delay.ms=60000, log.segment.bytes = 10000
, когда размер сегмента журнала нарушен. kafka отмечает сегмент для удаления только тогда, когда самая большая временная метка проходит log.retention.ms ie. 60se c в данном случае.
Случай 2:
Если log.segment.bytes
большой и сегмент журнала не вращается, пока не будет передано log.retention.ms
, kafka будет ждать log.segment.delete.delay.ms
и удалите лог