Class KafkaEventQueue

Namespace

Org.Apache.Kafka.Queue

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html

public class KafkaEventQueue : EventQueue, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IEventQueue, IAutoCloseable

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AutoCloseable>

AutoCloseable

EventQueue

KafkaEventQueue

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IEventQueue

IAutoCloseable

Inherited Members

EventQueue.IsEmpty()

EventQueue.Append(EventQueue.Event)

EventQueue.AppendWithDeadline(long, EventQueue.Event)

EventQueue.Prepend(EventQueue.Event)

EventQueue.ScheduleDeferred(String, UnaryOperator<OptionalLong>, EventQueue.Event)

Constructors

KafkaEventQueue(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KafkaEventQueue(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

KafkaEventQueue(Time, LogContext, String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#%3Cinit%3E(org.apache.kafka.common.utils.Time,org.apache.kafka.common.utils.LogContext,java.lang.String)

public KafkaEventQueue(Time arg0, LogContext arg1, String arg2)

Parameters

arg0 Time

Time

arg1 LogContext

LogContext

arg2 String

String

KafkaEventQueue(Time, LogContext, String, Event)

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#%3Cinit%3E(org.apache.kafka.common.utils.Time,org.apache.kafka.common.utils.LogContext,java.lang.String,org.apache.kafka.queue.EventQueue.Event)

public KafkaEventQueue(Time arg0, LogContext arg1, String arg2, EventQueue.Event arg3)

Parameters

arg0 Time

Time

arg1 LogContext

LogContext

arg2 String

String

arg3 EventQueue.Event

EventQueue.Event

KafkaEventQueue(Time, LogContext, String, Event, BiConsumer<Long, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#%3Cinit%3E(org.apache.kafka.common.utils.Time,org.apache.kafka.common.utils.LogContext,java.lang.String,org.apache.kafka.queue.EventQueue.Event,java.util.function.BiConsumer)

public KafkaEventQueue(Time arg0, LogContext arg1, String arg2, EventQueue.Event arg3, BiConsumer<Long, Long> arg4)

Parameters

arg0 Time

Time

arg1 LogContext

LogContext

arg2 String

String

arg3 EventQueue.Event

EventQueue.Event

arg4 BiConsumer<Long, Long>

BiConsumer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

EVENT_HANDLER_THREAD_SUFFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#EVENT_HANDLER_THREAD_SUFFIX

public static String EVENT_HANDLER_THREAD_SUFFIX { get; set; }

Property Value

String

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

BeginShutdown(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#beginShutdown(java.lang.String)

public void BeginShutdown(String arg0)

Parameters

arg0 String

String

CancelDeferred(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#cancelDeferred(java.lang.String)

public void CancelDeferred(String arg0)

Parameters

arg0 String

String

Close()

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#close()

public void Close()

Exceptions

InterruptedException

CreatePoolableInstance(Time, LogContext, String)

HPA initializer for KafkaEventQueue(Org.Apache.Kafka.Common.Utils.Time arg0, Org.Apache.Kafka.Common.Utils.LogContext arg1, Java.Lang.String arg2)

public static KafkaEventQueue CreatePoolableInstance(Time arg0, LogContext arg1, String arg2)

Parameters

arg0 Time

arg1 LogContext

arg2 String

Returns

KafkaEventQueue

CreatePoolableInstance(Time, LogContext, String, Event)

HPA initializer for KafkaEventQueue(Org.Apache.Kafka.Common.Utils.Time arg0, Org.Apache.Kafka.Common.Utils.LogContext arg1, Java.Lang.String arg2, Org.Apache.Kafka.Queue.EventQueue.Event arg3)

public static KafkaEventQueue CreatePoolableInstance(Time arg0, LogContext arg1, String arg2, EventQueue.Event arg3)

Parameters

arg0 Time

arg1 LogContext

arg2 String

arg3 EventQueue.Event

Returns

KafkaEventQueue

CreatePoolableInstance(Time, LogContext, String, Event, BiConsumer<Long, Long>)

HPA initializer for KafkaEventQueue(Org.Apache.Kafka.Common.Utils.Time arg0, Org.Apache.Kafka.Common.Utils.LogContext arg1, Java.Lang.String arg2, Org.Apache.Kafka.Queue.EventQueue.Event arg3, Java.Util.Function.BiConsumer%3CJava.Lang.Long, Java.Lang.Long%3E arg4)

public static KafkaEventQueue CreatePoolableInstance(Time arg0, LogContext arg1, String arg2, EventQueue.Event arg3, BiConsumer<Long, Long> arg4)

Parameters

arg0 Time

arg1 LogContext

arg2 String

arg3 EventQueue.Event

arg4 BiConsumer<Long, Long>

Returns

KafkaEventQueue

Enqueue(EventInsertionType, String, UnaryOperator<OptionalLong>, Event)

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#enqueue(org.apache.kafka.queue.EventQueue.EventInsertionType,java.lang.String,java.util.function.UnaryOperator,org.apache.kafka.queue.EventQueue.Event)

public void Enqueue(EventQueue.EventInsertionType arg0, String arg1, UnaryOperator<OptionalLong> arg2, EventQueue.Event arg3)

Parameters

arg0 EventQueue.EventInsertionType

EventQueue.EventInsertionType

arg1 String

String

arg2 UnaryOperator<OptionalLong>

UnaryOperator

arg3 EventQueue.Event

EventQueue.Event

FirstDeferredIfIdling()

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#firstDeferredIfIdling()

public Optional<EventQueue.Event> FirstDeferredIfIdling()

Returns

Optional<EventQueue.Event>

Optional

Size()

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#size()

public int Size()

Returns

int

int

Time()

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#time()

public Time Time()

Returns

Time

Time

Wakeup()

https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/4.2.1/org/apache/kafka/queue/KafkaEventQueue.html#wakeup()

public void Wakeup()