dongnuo123 commented on code in PR #20055:
URL: https://github.com/apache/kafka/pull/20055#discussion_r2180181011
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java:
##########
@@ -132,12 +189,15 @@ public ConsumerGroupMember build() {
case STABLE:
// When the member is in the STABLE state, we verify if a newer
// epoch (or target assignment) is available. If it is, we can
- // reconcile the member towards it. Otherwise, we return.
+ // reconcile the member towards it. Otherwise, we ensure the
+ // assignment is consistent with the subscribed topics, if
changed.
if (member.memberEpoch() != targetAssignmentEpoch) {
return computeNextAssignment(
member.memberEpoch(),
member.assignedPartitions()
);
+ } else if (hasSubscriptionChanged) {
Review Comment:
To confirm, this applies to 1) client side assignor 2) subscription changed
to an unresolved regex. Is it correct?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
