qianrui created KAFKA-9332: ------------------------------ Summary: 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.2.0, 2.0.0 Reporter: qianrui 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)