Hi Ahmed, I think this bug KAFKA-12495 <https://issues.apache.org/jira/browse/KAFKA-12495> is the issue you described, which is under code review now. If not, please open another JIRA ticket to track it.
Thanks. Luke On Tue, Apr 6, 2021 at 4:18 AM Thouqueer Ahmed < thouqueer.ah...@maplelabs.com> wrote: > Hi, > What would happen when new worker joins after the > synchronization barrier ? > > As per code -> performTaskAssignment function of IncrementalAssignor -> > Boolean canRevoke is false when it is called during the 2nd rebalance. > Hence revocation is skipped and only assignment is done. > This would lead to imbalance in #tasks/#connectors. > > How is this case handled ? > > Thanks, > Ahmed > >
