[
https://issues.apache.org/jira/browse/KAFKA-4881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006306#comment-16006306
]
ASF GitHub Bot commented on KAFKA-4881:
---------------------------------------
GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/3025
KAFKA-4881: add internal.leave.group.config to consumer
Backport from https://github.com/apache/kafka/pull/2650
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dguy/kafka kafka-4881-bp
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3025.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 #3025
----
commit 1eb6b1af11100b406b067f8c1e1d0e99c6543836
Author: Damian Guy <[email protected]>
Date: 2017-03-27T17:30:38Z
backport from trunk
----
> Add internal leave.group.on.close config to consumer
> -----------------------------------------------------
>
> Key: KAFKA-4881
> URL: https://issues.apache.org/jira/browse/KAFKA-4881
> Project: Kafka
> Issue Type: New Feature
> Components: clients
> Reporter: Damian Guy
> Assignee: Damian Guy
> Fix For: 0.11.0.0
>
>
> In streams we need to reduce the number of rebalances as they cause expensive
> shuffling of state during {{onPartitionsAssigned}} and
> {{onPartitionsRevoked}}. To achieve this we can choose to not send leave the
> group when a streams consumer is closed. This means that during bounces (with
> appropriate session timeout settings) we will see at most one rebalance per
> instance bounce.
> As this is an optimization that is only relevant to streams at the moment,
> initially we will do this by adding an internal config to the consumer
> {{leave.group.on.close}}, this will default to true. When it is set to false
> {{AbstractCoordinator}} won't send the {{LeaveGroupRequest}}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
