[
https://issues.apache.org/jira/browse/KAFKA-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16078169#comment-16078169
]
ASF GitHub Bot commented on KAFKA-5570:
---------------------------------------
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/3503
KAFKA-5570: Join request's timeout should be slightly higher than the
rebalance timeout
- Introduce per request timeouts in NetworkClient
- Use rebalanceTimeout + 5s for join request timeout
- A few minor clean-ups in NetworkClient and ConsumerNetworkClient
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka-5570-join-request-timeout-higher-than-rebalance-timeout
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3503.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3503
----
commit 1a1060f3a04f9f7e376df9df953ff47d829ca076
Author: Ismael Juma <[email protected]>
Date: 2017-07-07T14:00:44Z
Introduce per request timeouts in NetworkClient
commit 6cb76f8e73ffe13870270a93b757caf72ed43a48
Author: Ismael Juma <[email protected]>
Date: 2017-07-07T14:07:07Z
Use rebalanceTimeout + 5s for join request timeout
commit 2dec4b149675e6158ec851b06117e606963afe49
Author: Ismael Juma <[email protected]>
Date: 2017-07-07T14:07:39Z
A few minor clean-ups in NetworkClient and ConsumerNetworkClient
----
> Join request's timeout should be slightly higher than the rebalance timeout
> ---------------------------------------------------------------------------
>
> Key: KAFKA-5570
> URL: https://issues.apache.org/jira/browse/KAFKA-5570
> Project: Kafka
> Issue Type: Improvement
> Reporter: Ismael Juma
> Assignee: Ismael Juma
>
> This is necessary because the join request blocks until the rebalance
> completes. The join request currently uses the same timeout as other consumer
> requests and this is the reason why the default request timeout for the
> consumer is 305 seconds (while the default rebalance timeout is 300 seconds).
> This JIRA is related to KAFKA-4237, but it doesn't include the part where we
> change the default request timeout for the consumer (as that has additional
> compatibility implications and requires a KIP).
> In order to implement this, we need to add to the NetworkClient the ability
> to do per request timeouts.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
