Package org.apache.kafka.streams.processor

Interface StateRestoreCallback

All Known Subinterfaces:
BatchingStateRestoreCallback
public interface StateRestoreCallback
Restoration logic for log-backed state stores upon restart, it takes one record at a time from the logs to apply to the restoring state.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    restore(byte[] key, byte[] value)
     

  • Method Details

    • restore

      void restore(byte[] key, byte[] value)