[KAFKA-12154] API and implementation for snapshot loading

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: replication
• Assignee: Jose Armando Garcia Sancio
• Reporter: Jose Armando Garcia Sancio
• Created: 07/Jan/21 01:25
• Updated: 01/May/21 17:06
• Resolved: 01/May/21 17:06

Description

Following changes need to be implemented:

1. Notify the Listener when a snapshot is available:

interface Listener<T> {
  void handleSnapshot(SnapshotReader<T> snapshot);

  ...
} 

It is possible that we can reuse the existing BatchReader<T> but I am not sure at this point. Whenever handleSnapshot is called the implementation should assume that the state has been rewound.

 

2. Update the ListenerContext when a snapshot is available:

class ListenerContext {
  void fireHandleSnapshot(SnapshotReader<T> snapshot);
}

Issue Links

• blocks: KAFKA-12155 Delay increasing the log start offset
• links to: GitHub Pull Request #10085