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)