lucasbru opened a new pull request, #20714: URL: https://github.com/apache/kafka/pull/20714
This adds code to pass committed partitions into ClassicGroup, StreamsGroup and ConsumerGroup. These are not used in validation yet, this is just preparation for later PRs. The partitions are passed as a supplier, so that we only instantiate the collection if we are not trying to commit with the latest member epoch. We also add variations of streams groups tests for the tests in OffsetMetadataManagerTest, which previously only tested the consumer group case. Right now the commit logic is exactly the same, but we will diverge in the following PRs. -- 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]
