Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-13617

Enhance delete-expired-group-metadata logging

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • offset manager
    • None

    Description

      Hi team,

      When you try to understand why a consumer group offset was expired, the default INFO logging on the group coordinator does not give much : 

      info(s"Removed $numOffsetsRemoved expired offsets in ${time.milliseconds() - currentTimestamp} milliseconds.")

      https://github.com/apache/kafka/blob/22d056c9b76c9bf8417d8701594d1fcee1c6a655/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala#L834

      Considering the rest of the available logs are at TRACE level if I'm not mistaking, and my use is mostly root cause analysis type of work, the INFO log is mostly what Kafka Admin get "post offset deletion"

      Would it be possible to enhance this log with the actual group/topic/partition that was removed please ? 

      Thank you

      Attachments

        Activity

          People

            Unassigned Unassigned
            nicolas.guyomar Nicolas Guyomar
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: