Table of Contents

Class StandbyUpdateListener

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

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html

public class StandbyUpdateListener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IStandbyUpdateListener
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
StandbyUpdateListener
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

Constructors

StandbyUpdateListener()

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

public StandbyUpdateListener()

Properties

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeListener_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

OnOnBatchLoaded

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html#onBatchLoaded-org.apache.kafka.common.TopicPartition-java.lang.String-org.apache.kafka.streams.processor.TaskId-long-long-long-

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

Property Value

Action<TopicPartition, String, TaskId, long, long, long>

Remarks

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

OnOnUpdateStart

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html#onUpdateStart-org.apache.kafka.common.TopicPartition-java.lang.String-long-

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

Property Value

Action<TopicPartition, String, long>

Remarks

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

OnOnUpdateSuspended

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html#onUpdateSuspended-org.apache.kafka.common.TopicPartition-java.lang.String-long-long-org.apache.kafka.streams.processor.StandbyUpdateListener.SuspendReason-

public Action<TopicPartition, String, long, long, StandbyUpdateListener.SuspendReason> OnOnUpdateSuspended { get; set; }

Property Value

Action<TopicPartition, String, long, long, StandbyUpdateListener.SuspendReason>

Remarks

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

Methods

InitializeHandlers()

Handlers initializer for StandbyUpdateListener

protected virtual void InitializeHandlers()

OnBatchLoaded(TopicPartition, String, TaskId, long, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html#onBatchLoaded-org.apache.kafka.common.TopicPartition-java.lang.String-org.apache.kafka.streams.processor.TaskId-long-long-long-

public virtual void OnBatchLoaded(TopicPartition arg0, String arg1, TaskId arg2, long arg3, long arg4, long arg5)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 TaskId

TaskId

arg3 long

long

arg4 long

long

arg5 long

long

OnUpdateStart(TopicPartition, String, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html#onUpdateStart-org.apache.kafka.common.TopicPartition-java.lang.String-long-

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

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

OnUpdateSuspended(TopicPartition, String, long, long, SuspendReason)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html#onUpdateSuspended-org.apache.kafka.common.TopicPartition-java.lang.String-long-long-org.apache.kafka.streams.processor.StandbyUpdateListener.SuspendReason-

public virtual void OnUpdateSuspended(TopicPartition arg0, String arg1, long arg2, long arg3, StandbyUpdateListener.SuspendReason arg4)

Parameters

arg0 TopicPartition

TopicPartition

arg1 String

String

arg2 long

long

arg3 long

long

arg4 StandbyUpdateListener.SuspendReason

StandbyUpdateListener.SuspendReason

Edit this page