[KAFKA-13113] Add unregister support to the RaftClient.

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 3.0.0
• Component/s: kraft
• Labels: kip-500
• Assignee: Jose Armando Garcia Sancio
• Reporter: Jose Armando Garcia Sancio
• Created: 21/Jul/21 02:25
• Updated: 24/Jul/21 04:56
• Resolved: 24/Jul/21 04:56

Description

Implement the following API:

interface RaftClient<T> {
  ListenerContext register(Listener<T>);
  void unregister(ListenerContext);
}

interface ListenerContext {
}

interface Listener<T> {
  void handleCommit(ListenerContext, BatchReader<T>);
  void handleSnapshot(ListenerContext, SnapshotReader<T>);
  void handleLeaderChange(ListenerContext, LeaderAndEpoch);
} 

Issue Links

• links to: GitHub Pull Request #11109