Table of Contents

Class KafkaShareConsumer<K, V>

Namespace
Org.Apache.Kafka.Clients.Consumer
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html

public class KafkaShareConsumer<K, V> : ShareConsumer<K, V>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IShareConsumer<K, V>, ICloseable, IAutoCloseable

Type Parameters

K
V
Inheritance
KafkaShareConsumer<K, V>
Implements
Derived
Inherited Members

Constructors

KafkaShareConsumer(Map<String, object>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#%3Cinit%3E(java.util.Map)

public KafkaShareConsumer(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

KafkaShareConsumer(Map<String, object>, Deserializer<K>, Deserializer<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#%3Cinit%3E(java.util.Map,org.apache.kafka.common.serialization.Deserializer,org.apache.kafka.common.serialization.Deserializer)

public KafkaShareConsumer(Map<String, object> arg0, Deserializer<K> arg1, Deserializer<V> arg2)

Parameters

arg0 Map<String, object>

Map

arg1 Deserializer<K>

Deserializer

arg2 Deserializer<V>

Deserializer

KafkaShareConsumer(Properties)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#%3Cinit%3E(java.util.Properties)

public KafkaShareConsumer(Properties arg0)

Parameters

arg0 Properties

Properties

KafkaShareConsumer(Properties, Deserializer<K>, Deserializer<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#%3Cinit%3E(java.util.Properties,org.apache.kafka.common.serialization.Deserializer,org.apache.kafka.common.serialization.Deserializer)

public KafkaShareConsumer(Properties arg0, Deserializer<K> arg1, Deserializer<V> arg2)

Parameters

arg0 Properties

Properties

arg1 Deserializer<K>

Deserializer

arg2 Deserializer<V>

Deserializer

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

Parameters

initializer IJVMBridgeBaseInitializer

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

Acknowledge(String, int, long, AcknowledgeType)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#acknowledge(java.lang.String,int,long,org.apache.kafka.clients.consumer.AcknowledgeType)

public void Acknowledge(String arg0, int arg1, long arg2, AcknowledgeType arg3)

Parameters

arg0 String

String

arg1 int

int

arg2 long

long

arg3 AcknowledgeType

AcknowledgeType

Acknowledge(ConsumerRecord<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#acknowledge(org.apache.kafka.clients.consumer.ConsumerRecord)

public void Acknowledge(ConsumerRecord<K, V> arg0)

Parameters

arg0 ConsumerRecord<K, V>

ConsumerRecord

Acknowledge(ConsumerRecord<K, V>, AcknowledgeType)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#acknowledge(org.apache.kafka.clients.consumer.ConsumerRecord,org.apache.kafka.clients.consumer.AcknowledgeType)

public void Acknowledge(ConsumerRecord<K, V> arg0, AcknowledgeType arg1)

Parameters

arg0 ConsumerRecord<K, V>

ConsumerRecord

arg1 AcknowledgeType

AcknowledgeType

AcquisitionLockTimeoutMs()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#acquisitionLockTimeoutMs()

public Optional<Integer> AcquisitionLockTimeoutMs()

Returns

Optional<Integer>

Optional

ClientInstanceId(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#clientInstanceId(java.time.Duration)

public Uuid ClientInstanceId(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Uuid

Uuid

Close()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#close()

public void Close()

Close(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#close(java.time.Duration)

public void Close(Duration arg0)

Parameters

arg0 Duration

Duration

CommitAsync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#commitAsync()

public void CommitAsync()

CommitSync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#commitSync()

public Map<TopicIdPartition, Optional<KafkaException>> CommitSync()

Returns

Map<TopicIdPartition, Optional<KafkaException>>

Map

CommitSync(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#commitSync(java.time.Duration)

public Map<TopicIdPartition, Optional<KafkaException>> CommitSync(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Map<TopicIdPartition, Optional<KafkaException>>

Map

CreatePoolableInstance(Map<String, object>)

HPA initializer for KafkaShareConsumer(Java.Util.Map%3CJava.Lang.String, object%3E arg0)

public static KafkaShareConsumer<K, V> CreatePoolableInstance(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Returns

KafkaShareConsumer<K, V>

CreatePoolableInstance(Map<String, object>, Deserializer<K>, Deserializer<V>)

HPA initializer for KafkaShareConsumer(Java.Util.Map%3CJava.Lang.String, object%3E arg0, Org.Apache.Kafka.Common.Serialization.Deserializer%3CK%3E arg1, Org.Apache.Kafka.Common.Serialization.Deserializer%3CV%3E arg2)

public static KafkaShareConsumer<K, V> CreatePoolableInstance(Map<String, object> arg0, Deserializer<K> arg1, Deserializer<V> arg2)

Parameters

arg0 Map<String, object>
arg1 Deserializer<K>
arg2 Deserializer<V>

Returns

KafkaShareConsumer<K, V>

CreatePoolableInstance(Properties)

HPA initializer for KafkaShareConsumer(Java.Util.Properties arg0)

public static KafkaShareConsumer<K, V> CreatePoolableInstance(Properties arg0)

Parameters

arg0 Properties

Returns

KafkaShareConsumer<K, V>

CreatePoolableInstance(Properties, Deserializer<K>, Deserializer<V>)

HPA initializer for KafkaShareConsumer(Java.Util.Properties arg0, Org.Apache.Kafka.Common.Serialization.Deserializer%3CK%3E arg1, Org.Apache.Kafka.Common.Serialization.Deserializer%3CV%3E arg2)

public static KafkaShareConsumer<K, V> CreatePoolableInstance(Properties arg0, Deserializer<K> arg1, Deserializer<V> arg2)

Parameters

arg0 Properties
arg1 Deserializer<K>
arg2 Deserializer<V>

Returns

KafkaShareConsumer<K, V>

Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#metrics()

public Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric> Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>() where ReturnExtendsOrg_Apache_Kafka_Common_Metric : Metric

Returns

Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>

Map

Type Parameters

ReturnExtendsOrg_Apache_Kafka_Common_Metric

Metric

Poll(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#poll(java.time.Duration)

public ConsumerRecords<K, V> Poll(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

ConsumerRecords<K, V>

ConsumerRecords

RegisterMetricForSubscription(KafkaMetric)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#registerMetricForSubscription(org.apache.kafka.common.metrics.KafkaMetric)

public void RegisterMetricForSubscription(KafkaMetric arg0)

Parameters

arg0 KafkaMetric

KafkaMetric

SetAcknowledgementCommitCallback(AcknowledgementCommitCallback)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#setAcknowledgementCommitCallback(org.apache.kafka.clients.consumer.AcknowledgementCommitCallback)

public void SetAcknowledgementCommitCallback(AcknowledgementCommitCallback arg0)

Parameters

arg0 AcknowledgementCommitCallback

AcknowledgementCommitCallback

Subscribe(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#subscribe(java.util.Collection)

public void Subscribe(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Subscription()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#subscription()

public Set<String> Subscription()

Returns

Set<String>

Set

UnregisterMetricFromSubscription(KafkaMetric)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#unregisterMetricFromSubscription(org.apache.kafka.common.metrics.KafkaMetric)

public void UnregisterMetricFromSubscription(KafkaMetric arg0)

Parameters

arg0 KafkaMetric

KafkaMetric

Unsubscribe()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#unsubscribe()

public void Unsubscribe()

Wakeup()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html#wakeup()

public void Wakeup()

Operators

implicit operator KafkaShareConsumer(KafkaShareConsumer<K, V>)

Converter from KafkaShareConsumer<K, V> to KafkaShareConsumer

public static implicit operator KafkaShareConsumer(KafkaShareConsumer<K, V> t)

Parameters

t KafkaShareConsumer<K, V>

Returns

KafkaShareConsumer
Edit this page