You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "qianrui (Jira)" <ji...@apache.org> on 2020/06/16 12:08:00 UTC

[jira] [Commented] (KAFKA-9332) change how to get joinGroupTimeoutMs

    [ https://issues.apache.org/jira/browse/KAFKA-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136585#comment-17136585 ] 

qianrui commented on KAFKA-9332:
--------------------------------

This problem has been solved

> change how to get joinGroupTimeoutMs
> ------------------------------------
>
>                 Key: KAFKA-9332
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9332
>             Project: Kafka
>          Issue Type: Improvement
>          Components: consumer
>    Affects Versions: 2.0.0, 2.2.0
>            Reporter: qianrui
>            Priority: Major
>             Fix For: 2.0.0
>
>
> in the AbstractCoordinator class
> int joinGroupTimeoutMs = Math.max(rebalanceTimeoutMs, rebalanceTimeoutMs + 5000);
> l think  rebalanceTimeoutMs + 5000 is always greater than rebalanceTimeoutMs，It would be better to write  joinGroupTimeoutMs = rebalanceTimeoutMs + 5000。



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