[KAFKA-4322] StateRestoreCallback begin and end indication

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.10.1.0
• Fix Version/s: 1.0.0
• Component/s: streams
• Flags: Patch
• Assignee: Mark Shelton
• Reporter: Mark Shelton
• Created: 20/Oct/16 14:02
• Updated: 22/Dec/17 20:26
• Resolved: 25/Aug/17 17:10

Description

In Kafka Streams, the StateRestoreCallback interface provides only a single method "restore(byte[] key, byte[] value)" that is called for every key-value pair to be restored.

It would be nice to have "beginRestore" and "endRestore" methods as part of StateRestoreCallback.

Kafka Streams would call "beginRestore" before restoring any keys, and would call "endRestore" when it determines that it is done. This allows an implementation, for example, to report on the number of keys restored and perform a commit after the last key was restored. Other uses are conceivable.

Issue Links

• relates to: KAFKA-5363 Add ability to batch restore and receive restoration stats.
• links to: GitHub Pull Request #2105
• links to: GitHub Pull Request #2105