Page History

public interface BatchingStateRestoreCallback extends StateRestoreCallback {

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

    void onRestoreStart(TopicPartition topicPartition, long startingOffset);

 
    void onBatchRestored(TopicPartition topicPartition, long batchEndOffset, long numRestored);

    void onRestoreEnd(TopicPartition topicPartition, long endOffset, long totalRestored);

}