You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "dengziming (Jira)" <ji...@apache.org> on 2020/11/06 09:15:00 UTC
[jira] [Commented] (KAFKA-9275) Print assignment and IP address in
the log message when consumer leaves/removed from the group
[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227259#comment-17227259 ]
dengziming commented on KAFKA-9275:
-----------------------------------
https://github.com/apache/kafka/pull/7826
> 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
> Assignee: dengziming
> Priority: Minor
>
> 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.
> Even better if we can send this reason to all other members that are affected by the rebalance. Currently, it takes forever to know what caused a rebalance when a consumer group continuously goes into rebalancing state due to one member keeps exceeding max.poll.intervals.ms.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)