Interface IStateRestoreListener

Namespace

Org.Apache.Kafka.Streams.Processor

Assembly

MASES.KNet.dll

Listener for Kafka StateRestoreListener. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase

public interface IStateRestoreListener : IJVMBridgeBase, IJVMBridgeDefinition

Inherited Members

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

Methods

OnBatchRestored(TopicPartition, String, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.5.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/3.5.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/3.5.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