Table of Contents

Class MockShareConsumer<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/MockShareConsumer.html

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

Type Parameters

K
V
Inheritance
MockShareConsumer<K, V>
Implements
Inherited Members

Constructors

MockShareConsumer()

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

public MockShareConsumer()

MockShareConsumer(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 MockShareConsumer(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/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.html#acquisitionLockTimeoutMs()

public Optional<Integer> AcquisitionLockTimeoutMs()

Returns

Optional<Integer>

Optional

AddRecord(ConsumerRecord<K, V>)

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

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

Parameters

arg0 ConsumerRecord<K, V>

ConsumerRecord

ClientInstanceId(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.html#commitAsync()

public void CommitAsync()

CommitSync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockShareConsumer.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/MockShareConsumer.html#commitSync(java.time.Duration)

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

Parameters

arg0 Duration

Duration

Returns

Map<TopicIdPartition, Optional<KafkaException>>

Map

CreatePoolableInstance()

HPA initializer for MockShareConsumer()

public static MockShareConsumer<K, V> CreatePoolableInstance()

Returns

MockShareConsumer<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/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.html#setAcknowledgementCommitCallback(org.apache.kafka.clients.consumer.AcknowledgementCommitCallback)

public void SetAcknowledgementCommitCallback(AcknowledgementCommitCallback arg0)

Parameters

arg0 AcknowledgementCommitCallback

AcknowledgementCommitCallback

SetClientInstanceId(Uuid)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockShareConsumer.html#setClientInstanceId(org.apache.kafka.common.Uuid)

public void SetClientInstanceId(Uuid arg0)

Parameters

arg0 Uuid

Uuid

Subscribe(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.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/MockShareConsumer.html#unsubscribe()

public void Unsubscribe()

Wakeup()

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

public void Wakeup()

Operators

implicit operator MockShareConsumer(MockShareConsumer<K, V>)

Converter from MockShareConsumer<K, V> to MockShareConsumer

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

Parameters

t MockShareConsumer<K, V>

Returns

MockShareConsumer
Edit this page