CompositeRestoreListener is a concrete BatchingStateRestoreCallback and a StateRestoreListener.

CompositeRestoreListener is created exclusively when ProcessorStateManager is requested to register a state store (and restores it from the changelog topic).

CompositeRestoreListener uses a StateRestoreListener in onRestoreStart, onBatchRestored and onRestoreEnd callbacks. A StateRestoreListener can be assigned using setUserRestoreListener method.

CompositeRestoreListener takes a single StateRestoreCallback when created.

Setting StateRestoreListener — setUserRestoreListener Method

void setUserRestoreListener(final StateRestoreListener userRestoreListener)

setUserRestoreListener simply sets the userRestoreListener to be the given StateRestoreListener.

setUserRestoreListener is used exclusively when StateRestorer is requested to set a StateRestoreListener.

results matching ""

    No results matching ""