public class LoggingStateRestoreListener extends Object implements org.apache.kafka.streams.processor.StateRestoreListener
Constructor and Description |
---|
LoggingStateRestoreListener() |
Modifier and Type | Method and Description |
---|---|
void |
onBatchRestored(org.apache.kafka.common.TopicPartition topicPartition,
String storeName,
long batchEndOffset,
long numRestored) |
void |
onRestoreEnd(org.apache.kafka.common.TopicPartition topicPartition,
String storeName,
long totalRestored) |
void |
onRestoreStart(org.apache.kafka.common.TopicPartition topicPartition,
String storeName,
long startingOffset,
long endingOffset) |
public void onRestoreStart(org.apache.kafka.common.TopicPartition topicPartition, String storeName, long startingOffset, long endingOffset)
onRestoreStart
in interface org.apache.kafka.streams.processor.StateRestoreListener
public void onBatchRestored(org.apache.kafka.common.TopicPartition topicPartition, String storeName, long batchEndOffset, long numRestored)
onBatchRestored
in interface org.apache.kafka.streams.processor.StateRestoreListener
public void onRestoreEnd(org.apache.kafka.common.TopicPartition topicPartition, String storeName, long totalRestored)
onRestoreEnd
in interface org.apache.kafka.streams.processor.StateRestoreListener
Copyright © 2020 Red Hat. All rights reserved.