[
https://issues.apache.org/jira/browse/KAFKA-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947081#comment-15947081
]
ASF GitHub Bot commented on KAFKA-4925:
---------------------------------------
GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/2758
KAFKA-4925: delay initial rebalance of consumer group [WiP]
Add new broker config, `group.initial.rebalance.delay.ms`, with a default
of 3 seconds.
When a consumer creates a new group, set the group's state to
InitialRebalance and delay the rebalance until
`min(group.initial.rebalance.delay.ms, rebalanceTimeout)`. As other members
join the group further delay the rebalance by
`min(group.initial.rebalance.delay.ms, remainingRebalanceTimeout)`. Once
`rebalanceTimeout` is hit or no new members join the group within the delay,
complete the rebalance.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dguy/kafka kafka-4925
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2758.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 #2758
----
commit 26acb81e51c3485c01e2d4f3b5fea50afa957574
Author: Damian Guy <[email protected]>
Date: 2017-03-29T13:05:59Z
delay initial rebalance of consumer group
----
> Add a configurable delay to the initial consumer group rebalance
> ----------------------------------------------------------------
>
> Key: KAFKA-4925
> URL: https://issues.apache.org/jira/browse/KAFKA-4925
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.10.2.0
> Reporter: Damian Guy
> Assignee: Damian Guy
> Fix For: 0.11.0.0
>
>
> As per
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-134%3A+Delay+initial+consumer+group+rebalance
> Add a broker side config that will enable the GroupCoordinator to delay the
> initial rebalance for a new/empty consumer group
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
