Package org.apache.kafka.streams.processor

Interface BatchingStateRestoreCallback

All Superinterfaces:
StateRestoreCallback
public interface BatchingStateRestoreCallback
extends StateRestoreCallback
Interface for batching restoration of a StateStore It is expected that implementations of this class will not call the StateRestoreCallback.restore(byte[], byte[]) method.

  • Method Summary

    Modifier and Type Method Description
    default void restore​(byte[] key, byte[] value)  
    void restoreAll​(Collection<KeyValue<byte[],​byte[]>> records)
    Called to restore a number of records.

  • Method Details

    • restoreAll

      void restoreAll​(Collection<KeyValue<byte[],​byte[]>> records)
      Called to restore a number of records. This method is called repeatedly until the StateStore is fulled restored.
      Parameters:
      records - the records to restore.

    • restore

      default void restore​(byte[] key, byte[] value)
      Specified by:
      restore in interface StateRestoreCallback