Table of Contents

Interface IStateRestoreListener

Namespace
Org.Apache.Kafka.Streams.Processor
Assembly
MASES.KNet.dll

Listener for Kafka StateRestoreListener. Extends IJVMBridgeBase

public interface IStateRestoreListener : IJVMBridgeBase, IJVMBridgeDefinition
Inherited Members

Methods

OnBatchRestored(TopicPartition, String, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/processor/StateRestoreListener.html#onBatchRestored(org.apache.kafka.common.TopicPartition,java.lang.String,long,long)

void OnBatchRestored(TopicPartition topicPartition, String storeName, long batchEndOffset, long numRestored)

Parameters

topicPartition TopicPartition
storeName String
batchEndOffset long
numRestored long

OnRestoreEnd(TopicPartition, String, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/processor/StateRestoreListener.html#onRestoreEnd(org.apache.kafka.common.TopicPartition,java.lang.String,long)

void OnRestoreEnd(TopicPartition topicPartition, String storeName, long totalRestored)

Parameters

topicPartition TopicPartition
storeName String
totalRestored long

OnRestoreStart(TopicPartition, String, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/processor/StateRestoreListener.html#onRestoreStart(org.apache.kafka.common.TopicPartition,java.lang.String,long,long)

void OnRestoreStart(TopicPartition topicPartition, String storeName, long startingOffset, long endingOffset)

Parameters

topicPartition TopicPartition
storeName String
startingOffset long
endingOffset long
Edit this page