[
https://issues.apache.org/jira/browse/KAFKA-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Guyomar updated KAFKA-13617:
------------------------------------
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
was:
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]
Would it be possible to enhance this log with the actual group/topic/partition
that was removed please ?
Thank you
> Enhance delete-expired-group-metadata logging
> ---------------------------------------------
>
> Key: KAFKA-13617
> URL: https://issues.apache.org/jira/browse/KAFKA-13617
> Project: Kafka
> Issue Type: Improvement
> Components: offset manager
> Reporter: Nicolas Guyomar
> Priority: Minor
>
> 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
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
