smjn opened a new pull request, #23147: URL: https://github.com/apache/kafka/pull/23147
* Per KIP-932's [Administration](https://cwiki.apache.org/confluence/spaces/KAFKA/pages/255070434/KIP-932+Queues+for+Kafka#KIP932:QueuesforKafka-Administration) section, AlterShareGroupOffsets must bump the group epoch and write a `ShareGroupMetadata` record before sending the `InitializeShareGroupState` request to the share coordinator, so the persisted state epoch matches the new group epoch. * `GroupMetadataManager.alterShareGroupOffsets` previously left the group epoch untouched and passed the current epoch into the persister request. * In this PR, the code bumps the epoch, emits the ShareGroupMetadata record, and uses the bumped epoch when building the `InitializeShareGroupState` request. * Adds tests verifying the epoch is bumped on a successful call and left unchanged when the call is rejected (e.g. non-empty group). -- 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]
