public interface RecordBatchingStateRestoreCallback extends BatchingStateRestoreCallback
Modifier and Type | Method and 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) |
void restoreBatch(java.util.Collection<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> records)
default void restoreAll(java.util.Collection<KeyValue<byte[],byte[]>> records)
BatchingStateRestoreCallback
StateStore
is fulled
restored.restoreAll
in interface BatchingStateRestoreCallback
records
- the records to restore.default void restore(byte[] key, byte[] value)
restore
in interface StateRestoreCallback