sjhajharia opened a new pull request, #18571: URL: https://github.com/apache/kafka/pull/18571
KAFKA-16720 aims at adding the support for the ListShareGroupOffsets AdminClient functionality. We started off with https://github.com/apache/kafka/pull/17775 but the same was getting a bit out of hand due to large number of file changes. Hence, to ensure smoother review, I am splitting it into two parts (hopefully) The Flow as per the KIP:  This PR mainly focusses on the handling of the ReadShareGroupStateSummary RPC which the Persister is supposed to issue to the Share Coordinator. Key Changes in this PR: - Introduction of the 3 files related to ListShareGroupOffsets (`ListShareGroupOffsetsOptions`, `ListShareGroupOffsetsResult`, `ListShareGroupOffsetsSpec`). - Introduction of the `Admin.java` function `listShareGroupOffsets()` and the corresponding changes to all inherited files. - Addition of some utility functions to `ReadShareGroupStateSummaryRequest` and `ReadShareGroupStateSummaryResponse`. - Handling of the `ReadShareGroupStateSummaryRequest` RPC in the `KafkaApis` (and the corresponding changes in `KafkaApisTest`). - Changes in the ShareCoordinator classes for the handling of this RPC. (This includes `ShareCoordinator`, `ShareCoordinatorShard` and `ShareCoordinatorService`). Unit tests were added to each of their respective test files. - Introduction of the `ReadStateSummaryHandler` in `PersisterStateManager`. Also changes to the `PersisterStateManagerTest` for the same. - Implementation of the `readSummary()` method in `DefaultStatePersister` and the changes in the Test file. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
