smjn opened a new pull request, #23190: URL: https://github.com/apache/kafka/pull/23190
Currently, the ShareCoordinatorShard.initializeState does not check for dedup request resulting in overwriting the stored state, in case of an out of order initializeState. This PR remedies the situation by comparing the stateEpoch and startOffset of the incoming request with the stored state and if both these values are equal, consider the request as no-op. This should not affect alterShareGroupOffsets as that request always brings a bumped up epoch - https://github.com/apache/kafka/pull/23147. New tests have been added to verify the changes. -- 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]
