Mark Shelton created KAFKA-4322:
-----------------------------------
Summary: StateRestoreCallback begin and end indication
Key: KAFKA-4322
URL: https://issues.apache.org/jira/browse/KAFKA-4322
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 0.10.0.1
Reporter: Mark Shelton
Assignee: Guozhang Wang
Priority: Minor
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
