...

The modifications introduced are in blue:

• The LogManager is triggeredvariable logsToBeDeleted contains logs and time schedule for deletion.

• The LogManager iterate on logsToBeDeleted will search for the logs to be deleted.
• The LogManager read the last offset consumed by all groups specified on "retention.notify.groups" property.
• The LogManager will remove the log.
• If the offset that has been removed is bigger than the last consumed offset for each group, log a line:

  • info(s"message with

    offset %d partition %d topic %s key %s has been removed without being consumed by group %s"

     $offset offset $partition partition $topic topic $key key has been removed without being consumed by group $group")
    
    

Compatibility, Deprecation, and Migration Plan

...