DelegatingStateRestoreListener

DelegatingStateRestoreListener is a concrete StateRestoreListener that simply intercepts the state-related events (e.g. onRestoreStart, onBatchRestored and onRestoreEnd) and notifies the user-defined global StateRestoreListener.

Note	`DelegatingStateRestoreListener` is a final class of KafkaStreams class and so has access to the internals of a `KafkaStreams` instance.

DelegatingStateRestoreListener is created for a KafkaStreams (that uses it to create a GlobalStreamThread and StreamThreads).

DelegatingStateRestoreListener takes no arguments when created.

void onBatchRestored(
  final TopicPartition topicPartition,
  final String storeName,
  final long batchEndOffset,
  final long numRestored)

Note	`onBatchRestored` is part of the StateRestoreListener Contract to…FIXME.

onBatchRestored…FIXME

void onRestoreEnd(
  final TopicPartition topicPartition,
  final String storeName,
  final long batchEndOffset,
  final long numRestored)

Note	`onRestoreEnd` is part of the StateRestoreListener Contract to…FIXME.

onRestoreEnd…FIXME

void onRestoreStart(
  final TopicPartition topicPartition,
  final String storeName,
  final long batchEndOffset,
  final long numRestored)

Note	`onRestoreStart` is part of the StateRestoreListener Contract to…FIXME.

onRestoreStart…FIXME

results matching ""