Class VerifiableConsumer

Namespace

Org.Apache.Kafka.Tools

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html

public class VerifiableConsumer : JVMBridgeBase<VerifiableConsumer>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeMain, ICloseable, IAutoCloseable, IOffsetCommitCallback, IConsumerRebalanceListener, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<VerifiableConsumer>

VerifiableConsumer

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeMain

ICloseable

IAutoCloseable

IOffsetCommitCallback

IConsumerRebalanceListener

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

VerifiableConsumer(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 VerifiableConsumer(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

VerifiableConsumer(KafkaConsumer<String, String>, PrintStream, String, int, bool, bool, bool)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#%3Cinit%3E(org.apache.kafka.clients.consumer.KafkaConsumer,java.io.PrintStream,java.lang.String,int,boolean,boolean,boolean)

public VerifiableConsumer(KafkaConsumer<String, String> arg0, PrintStream arg1, String arg2, int arg3, bool arg4, bool arg5, bool arg6)

Parameters

arg0 KafkaConsumer<String, String>

KafkaConsumer

arg1 PrintStream

PrintStream

arg2 String

String

arg3 int

int

arg4 bool

bool

arg5 bool

bool

arg6 bool

bool

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

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

Close()

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#close()

public void Close()

CommitSync(Map<TopicPartition, OffsetAndMetadata>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#commitSync(java.util.Map)

public void CommitSync(Map<TopicPartition, OffsetAndMetadata> arg0)

Parameters

arg0 Map<TopicPartition, OffsetAndMetadata>

Map

CreatePoolableInstance(KafkaConsumer<String, String>, PrintStream, String, int, bool, bool, bool)

HPA initializer for VerifiableConsumer(Org.Apache.Kafka.Clients.Consumer.KafkaConsumer%3CJava.Lang.String, Java.Lang.String%3E arg0, Java.Io.PrintStream arg1, Java.Lang.String arg2, int arg3, bool arg4, bool arg5, bool arg6)

public static VerifiableConsumer CreatePoolableInstance(KafkaConsumer<String, String> arg0, PrintStream arg1, String arg2, int arg3, bool arg4, bool arg5, bool arg6)

Parameters

arg0 KafkaConsumer<String, String>

arg1 PrintStream

arg2 String

arg3 int

arg4 bool

arg5 bool

arg6 bool

Returns

VerifiableConsumer

Main(String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#main(java.lang.String[])

public static void Main(String[] arg0)

Parameters

arg0 String[]

String

OnComplete(Map<TopicPartition, OffsetAndMetadata>, JVMBridgeException)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#onComplete(java.util.Map,java.lang.Exception)

public void OnComplete(Map<TopicPartition, OffsetAndMetadata> arg0, JVMBridgeException arg1)

Parameters

arg0 Map<TopicPartition, OffsetAndMetadata>

Map

arg1 JVMBridgeException

Exception

OnPartitionsAssigned(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#onPartitionsAssigned(java.util.Collection)

public void OnPartitionsAssigned(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

OnPartitionsRevoked(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#onPartitionsRevoked(java.util.Collection)

public void OnPartitionsRevoked(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Run()

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.1/org/apache/kafka/tools/VerifiableConsumer.html#run()

public void Run()

Operators

implicit operator Closeable(VerifiableConsumer)

Converter from VerifiableConsumer to Closeable

public static implicit operator Closeable(VerifiableConsumer t)

Parameters

t VerifiableConsumer

Returns

Closeable

implicit operator ConsumerRebalanceListener(VerifiableConsumer)

Converter from VerifiableConsumer to ConsumerRebalanceListener

public static implicit operator ConsumerRebalanceListener(VerifiableConsumer t)

Parameters

t VerifiableConsumer

Returns

ConsumerRebalanceListener

implicit operator OffsetCommitCallback(VerifiableConsumer)

Converter from VerifiableConsumer to OffsetCommitCallback

public static implicit operator OffsetCommitCallback(VerifiableConsumer t)

Parameters

t VerifiableConsumer

Returns

OffsetCommitCallback