Page History

public interface BatchingStateRestoreCallback extends StateRestoreCallback {

   void restoreAll(Collection<KeyValue<byte[], byte []>> records);
}
 
 
public interface StateRestoreListener {

    void onRestoreStart(TopicPartitionString topicPartitionstoreName, long startingOffset, long endOffset);

    void onBatchRestored(TopicPartitionString topicPartitionstoreName, long batchEndOffset, long numRestored);

    void onRestoreEnd(TopicPartitionString topicPartitionstoreName, long endOffset, long totalRestored);

}