Damian Guy created KAFKA-4881:
---------------------------------

             Summary: 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)

Reply via email to