[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16301920#comment-16301920 ] 

ASF GitHub Bot commented on KAFKA-4322:
---------------------------------------

guozhangwang commented on issue #2105: KAFKA-4322 StateRestoreCallback begin and end indication
URL: https://github.com/apache/kafka/pull/2105#issuecomment-353669434
 
 
   Closing for cleanup.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> 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.1.0
>            Reporter: Mark Shelton
>            Assignee: Mark Shelton
>            Priority: Minor
>             Fix For: 1.0.0
>
>
> 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.4.14#64029)