[
https://issues.apache.org/jira/browse/KAFKA-19276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17952525#comment-17952525
]
Lucas Brutschy commented on KAFKA-19276:
----------------------------------------
[~bloku] feel free to take a stab at it. Would be happy to review the PR
> Trigger rebalance when assignment related configurations are updated
> --------------------------------------------------------------------
>
> Key: KAFKA-19276
> URL: https://issues.apache.org/jira/browse/KAFKA-19276
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Lucas Brutschy
> Priority: Major
>
> In KIP-1071, there are configurations that affect the assignment, and that
> can be configured dynamically. Those are:
> * streams.num.standby.replicas
> * streams.assignor.name
> * streams.num.warmup.replicas
> * streams.acceptable.recovery.lag
> However, only the first one is currently implemented.
> We should implement a generic mechanism to trigger a rebalance on the next
> heartbeat into a streams group, when any of the above group-level
> configurations have been changed.
>
> Triggering a rebalance would mean setting the `bumpGroupEpoch` flag here:
> [https://github.com/apache/kafka/blob/trunk/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java#L1933]
>
> Detecting a group config change would probably happen here:
> [https://github.com/apache/kafka/blob/trunk/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfigManager.java#L58]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
