apoorvmittal10 opened a new pull request, #22407:
URL: https://github.com/apache/kafka/pull/22407
This PR integrates the `LogReader` and `PartitionMetadataProvider`
abstractions (introduced in #22389) into the share fetch path, replacing direct
ReplicaManager dependencies in DelayedShareFetch, SharePartition,
SharePartitionManager, and ShareFetchUtils.
#### What Changed
Core classes now accept LogReader and PartitionMetadataProvider
abstractions instead of ReplicaManager. SharePartitionManager instantiates the
default ReplicaManager-backed implementations and wires them through the
dependency graph.
SharePartition uses a Consumer<DelayedShareFetchKey> for delayed request
notifications instead of calling ReplicaManager directly.
--
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]
