squah-confluent opened a new pull request, #23888: URL: https://github.com/apache/kafka/pull/23888
InitMapValue now copies its partitions with Set.copyOf, so that the share group state partition metadata can be shared without defensive copies, such as with assignors offloaded to another thread. Add withAddedPartitions and withRemovedPartitions to derive new values, and a constructor taking a Collection for the partition lists in records. Use them in GroupMetadataManager and remove the copies that are no longer needed. combineInitMaps reuses a value when only one of the maps has the topic, and initializeShareGroupState no longer deep copies the initializing topics to remove partitions in place. initializedShareGroupPartitions and sharePartitionsEligibleForOffsetDeletion no longer copy the partitions. The partitions of the immutable sets are iterated in an unspecified order, so tests now compare them regardless of order. Co-Authored-By: Claude Opus 5.5 <[email protected]> -- 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]
