Table of Contents

Class StateRestoreListener

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

Listener for Kafka StateRestoreListener. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IStateRestoreListener

public class StateRestoreListener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IStateRestoreListener, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
StateRestoreListener
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeListener.Dispose()
JVMBridgeListener.AutoInit
JVMBridgeListener.IsBridgeStatic
JVMBridgeListener.IsBridgeCloseable
JVMBridgeListener.IsBridgeListener
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()
JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])
JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz
JVMBridgeBase<JVMBridgeListener>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeInterface
JVMBridgeBase.IsBridgeAbstract

Remarks

Dispose the object to avoid a resource leak, the object contains a reference to the corresponding JVM object

Constructors

StateRestoreListener()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public StateRestoreListener()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnOnBatchRestored

public Action<TopicPartition, String, long, long> OnOnBatchRestored { get; set; }

Property Value

Action<TopicPartition, String, long, long>

Remarks

If OnOnBatchRestored has a value it takes precedence over corresponding class method

OnOnRestoreEnd

public Action<TopicPartition, String, long> OnOnRestoreEnd { get; set; }

Property Value

Action<TopicPartition, String, long>

Remarks

If OnOnRestoreEnd has a value it takes precedence over corresponding class method

OnOnRestoreStart

public Action<TopicPartition, String, long, long> OnOnRestoreStart { get; set; }

Property Value

Action<TopicPartition, String, long, long>

Remarks

If OnOnRestoreStart has a value it takes precedence over corresponding class method

OnOnRestoreSuspended

public Action<TopicPartition, String, long> OnOnRestoreSuspended { get; set; }

Property Value

Action<TopicPartition, String, long>

Remarks

If OnOnRestoreSuspended has a value it takes precedence over corresponding class method

Methods

InitializeHandlers()

Handlers initializer for StateRestoreListener

protected virtual void InitializeHandlers()

OnBatchRestored(TopicPartition, String, long, long)

public virtual void OnBatchRestored(TopicPartition arg0, String arg1, long arg2, long arg3)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

arg3 long

long

OnRestoreEnd(TopicPartition, String, long)

public virtual void OnRestoreEnd(TopicPartition arg0, String arg1, long arg2)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

OnRestoreStart(TopicPartition, String, long, long)

public virtual void OnRestoreStart(TopicPartition arg0, String arg1, long arg2, long arg3)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

arg3 long

long

OnRestoreSuspended(TopicPartition, String, long)

public virtual void OnRestoreSuspended(TopicPartition arg0, String arg1, long arg2)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

Remarks

The method invokes the default implementation in the JVM interface using OnRestoreSuspendedDefault(TopicPartition, String, long); override the method to implement a different behavior

OnRestoreSuspendedDefault(TopicPartition, String, long)

public void OnRestoreSuspendedDefault(TopicPartition arg0, String arg1, long arg2)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

Remarks

The method invokes the default implementation in the JVM interface