[KAFKA-13803] Refactor Leader API Access

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.3.0
• Assignee: Rittika Adhikari
• Reporter: Rittika Adhikari
• Reviewer: Jun Rao
• Created: 06/Apr/22 21:50
• Updated: 03/Jun/22 16:12
• Resolved: 03/Jun/22 16:12

Description

Currently, AbstractFetcherThread has a series of protected APIs which control access to the Leader. ReplicaFetcherThread and ReplicaAlterLogDirsThread respectively override these protected APIs and handle access to the Leader in a remote broker leader and a local leader context.

We propose to move these protected APIs to a LeaderEndPoint interface, which will serve all fetches from the Leader. We will implement a RemoteLeaderEndPoint and a LocalLeaderEndPoint accordingly. This change will greatly simplify our existing follower fetch code.

Issue Links

• links to: GitHub Pull Request #12005