AndrewJSchofield commented on PR #18894: URL: https://github.com/apache/kafka/pull/18894#issuecomment-2658962193
@smjn The expected flow is as follows: * `Admin.listShareGroupOffsets` is called with an empty collection of `TopicPartition` in the `ListShareGroupOffsetsSpec`. This means "list all offsets for this share group". * The group coordinator will compile a list of the topic-partitions in the share group (share-partitions). This will be imperfect until the initialize work that you mention, but I anticipate that `GroupCoordinatorShare.sharePartitions(List<String>, long)` will be used and that the response from this will be improved (fixed) as a result of the intialize work that you mention. * The group coordinator will then issue `ReadShareGroupStateSummary` requests to the share coordinator shards responsible for those share-partitions' state. -- 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]
