kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Badai Aqrandista (Jira)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group
Date Fri, 06 Dec 2019 00:33:00 GMT
Badai Aqrandista created KAFKA-9275:
---------------------------------------

             Summary: Print assignment and IP address in the log message when consumer leaves/removed
from the group
                 Key: KAFKA-9275
                 URL: https://issues.apache.org/jira/browse/KAFKA-9275
             Project: Kafka
          Issue Type: Improvement
            Reporter: Badai Aqrandista


In order to simplify identification of which member is causing rebalance, can we add the IP
address and the list of topic-partitions assigned to the member that leaves/removed from the
group?

And especially in the "reason" string for rebalance: 

https://github.com/apache/kafka/blob/2.4/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala#L964

https://github.com/apache/kafka/blob/2.4/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala#L972

https://github.com/apache/kafka/blob/2.4/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala#L1144

https://github.com/apache/kafka/blob/2.4/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala#L493


This will allow a much faster investigation when a consumer group is stuck in rebalancing
state.




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message