Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-4322

StateRestoreCallback begin and end indication

Agile BoardAttach filesAttach ScreenshotVotersStop watchingWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 0.10.1.0
    • Fix Version/s: 1.0.0
    • Component/s: streams
    • Labels:
      None
    • Flags:
      Patch

      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.

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              markshelton Mark Shelton
              Reporter:
              markshelton Mark Shelton

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment