chickenchickenlove opened a new pull request, #23705: URL: https://github.com/apache/kafka/pull/23705
Fixes KAFKA-21212 When a Streams static member restarted after removing `client.rack`, the coordinator retained the previous rack ID. During static member replacement, the coordinator copies the previous member’s metadata, then applies the incoming updates. Because `maybeUpdateRackId` treats null as unchanged, the joining request could not clear the copied rack ID. This left stale rack information in group descriptions and custom assignor inputs. This change distinguishes joining requests from regular heartbeats, following the existing handling of `userEndpoint`. Joining requests now apply the rack ID directly, including null to clear the previous value. Regular heartbeats continue to preserve the existing rack ID when the field is omitted. Clearing a previously configured rack ID also allows the existing metadata change detection to bump the group epoch and trigger assignment recomputation. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
