chirag-wadhwa5 opened a new pull request, #20852: URL: https://github.com/apache/kafka/pull/20852
This PR is part of [KIP-1226](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1226%3A+Introducing+Share+Partition+Lag+Persistence+and+Retrieval). This PR introduces an implementation class NetworkPartitionMetadataClient for PartitionMetadataClient, that uses a NetworkClient to send ListOffsetsRequest to the destination node. The destination node should be the leader broker for the partitions in the request and is retrieved from MetadataCache. This new imple class will later be used in GroupCoordinatorService to find the partition end offsets while computing share partition lag for DescribeShareGroupOffsets request. -- 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]
