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/4.0.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html

public class StandbyUpdateListener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IStandbyUpdateListener
Inheritance
StandbyUpdateListener
Implements
Derived
Inherited Members

Constructors

StandbyUpdateListener()

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

public StandbyUpdateListener()

StandbyUpdateListener(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 StandbyUpdateListener(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

OnOnBatchLoaded

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