Class StateRestoreListener
Listener for Kafka StateRestoreListener. Extends JVMBridgeListener, implements IStateRestoreListener
public class StateRestoreListener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IStateRestoreListener, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
StateRestoreListener
- Implements
- Derived
- Inherited Members
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()StateRestoreListener(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public StateRestoreListener(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
OnOnBatchRestored
public Action<TopicPartition, String, long, long> OnOnBatchRestored { get; set; }Property Value
Remarks
If OnOnBatchRestored has a value it takes precedence over corresponding class method
OnOnRestoreEnd
public Action<TopicPartition, String, long> OnOnRestoreEnd { get; set; }Property Value
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
Remarks
If OnOnRestoreStart has a value it takes precedence over corresponding class method
OnOnRestoreSuspended
public Action<TopicPartition, String, long> OnOnRestoreSuspended { get; set; }Property Value
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
arg0TopicPartitionarg1Stringarg2longarg3long
OnRestoreEnd(TopicPartition, String, long)
public virtual void OnRestoreEnd(TopicPartition arg0, String arg1, long arg2)Parameters
arg0TopicPartitionarg1Stringarg2long
OnRestoreStart(TopicPartition, String, long, long)
public virtual void OnRestoreStart(TopicPartition arg0, String arg1, long arg2, long arg3)Parameters
arg0TopicPartitionarg1Stringarg2longarg3long
OnRestoreSuspended(TopicPartition, String, long)
public virtual void OnRestoreSuspended(TopicPartition arg0, String arg1, long arg2)Parameters
arg0TopicPartitionarg1Stringarg2long
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
arg0TopicPartitionarg1Stringarg2long
Remarks
The method invokes the default implementation in the JVM interface