Interface RecordBatchingStateRestoreCallback
-
- All Superinterfaces:
BatchingStateRestoreCallback
,StateRestoreCallback
public interface RecordBatchingStateRestoreCallback extends BatchingStateRestoreCallback
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default void
restoreAll(Collection<KeyValue<byte[],byte[]>> records)
Called to restore a number of records.void
restoreBatch(Collection<ConsumerRecord<byte[],byte[]>> records)
-
Methods inherited from interface org.apache.kafka.streams.processor.BatchingStateRestoreCallback
restore
-
-
-
-
Method Detail
-
restoreBatch
void restoreBatch(Collection<ConsumerRecord<byte[],byte[]>> records)
-
restoreAll
default void restoreAll(Collection<KeyValue<byte[],byte[]>> records)
Description copied from interface:BatchingStateRestoreCallback
Called to restore a number of records. This method is called repeatedly until theStateStore
is fulled restored.- Specified by:
restoreAll
in interfaceBatchingStateRestoreCallback
- Parameters:
records
- the records to restore.
-
-