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 fully restored.
      Parameters:
      records - the records to restore.

    • restore

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