Package org.apache.kafka.streams.processor

Interface StateRestoreCallback

All Known Subinterfaces:

BatchingStateRestoreCallback, RecordBatchingStateRestoreCallback

public interface StateRestoreCallback

Restoration logic for log-backed state stores upon restart, it takes one record at a time from the logs to apply to the restoring state.

Method Summary

Modifier and Type	Method	Description
void	restore(byte[] key, byte[] value)

Method Detail

restore

void restore(byte[] key,
             byte[] value)