Interface RecordBatchingStateRestoreCallback
-
- All Superinterfaces:
BatchingStateRestoreCallback
,StateRestoreCallback
- All Known Implementing Classes:
CompositeRestoreListener
public interface RecordBatchingStateRestoreCallback extends BatchingStateRestoreCallback
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default void
restore(byte[] key, byte[] value)
default void
restoreAll(java.util.Collection<KeyValue<byte[],byte[]>> records)
Called to restore a number of records.void
restoreBatch(java.util.Collection<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> records)
-
-
-
Method Detail
-
restoreBatch
void restoreBatch(java.util.Collection<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> records)
-
restoreAll
default void restoreAll(java.util.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.
-
restore
default void restore(byte[] key, byte[] value)
- Specified by:
restore
in interfaceStateRestoreCallback
-
-