org.apache.kafka.streams.processor

Interface StateRestoreCallback

All Known Subinterfaces:

BatchingStateRestoreCallback

All Known Implementing Classes:

AbstractNotifyingBatchingRestoreCallback, AbstractNotifyingRestoreCallback

@InterfaceStability.Evolving
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 and Description
void	restore(byte[] key, byte[] value)

Method Detail

restore

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