rittikaadhikari opened a new pull request, #12005: URL: https://github.com/apache/kafka/pull/12005
This PR refactors the leader API access in the follower fetch path. Added a `LeaderEndPoint` interface which serves all access to the leader. Added a `LocalLeaderEndPoint` and a `RemoteLeaderEndPoint` which implements the `LeaderEndPoint` interface to handle fetches from leader in local & remote storage respectively. Modified `ReplicaAlterLogDirsThread` and `ReplicaFetcherThread` to accept a `LeaderEndPoint`, which is subsequently used to handle fetches. Modified corresponding tests to account for the `LeaderEndPoint` refactor. Currently in the process of adding test cases which directly test the fetch functions in `LocalLeaderEndPoint` and `RemoteLeaderEndPoint`. -- 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
