Class MockConsumer<K, V>

Namespace

Org.Apache.Kafka.Clients.Consumer

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html

public class MockConsumer<K, V> : Consumer<K, V>, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IConsumer<K, V>, IConsumer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

V

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AutoCloseable>

AutoCloseable

Closeable

Consumer<K, V>

MockConsumer<K, V>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IJVMBridgeBaseStatic

IConsumer<K, V>

IConsumer

IJVMBridgeBase

IJVMBridgeDefinition

IDisposable

ICloseable

IAutoCloseable

Inherited Members

Consumer<K, V>.BridgeClassName

Consumer<K, V>.IsBridgeAbstract

Consumer<K, V>.IsBridgeCloseable

Consumer<K, V>.IsBridgeInterface

Consumer<K, V>.IsBridgeStatic

Consumer<K, V>.PartitionsFor(String, Duration)

Consumer<K, V>.PartitionsFor(String)

Consumer<K, V>.ListTopics()

Consumer<K, V>.ListTopics(Duration)

Consumer<K, V>.Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

Consumer<K, V>.BeginningOffsets(Collection<TopicPartition>, Duration)

Consumer<K, V>.BeginningOffsets(Collection<TopicPartition>)

Consumer<K, V>.EndOffsets(Collection<TopicPartition>, Duration)

Consumer<K, V>.EndOffsets(Collection<TopicPartition>)

Consumer<K, V>.Committed(Set<TopicPartition>, Duration)

Consumer<K, V>.Committed(Set<TopicPartition>)

Consumer<K, V>.OffsetsForTimes(Map<TopicPartition, Long>, Duration)

Consumer<K, V>.OffsetsForTimes(Map<TopicPartition, Long>)

Consumer<K, V>.CurrentLag(TopicPartition)

Consumer<K, V>.Subscription()

Consumer<K, V>.Assignment()

Consumer<K, V>.Paused()

Consumer<K, V>.Position(TopicPartition, Duration)

Consumer<K, V>.Position(TopicPartition)

Consumer<K, V>.GroupMetadata()

Consumer<K, V>.Poll(Duration)

Consumer<K, V>.ClientInstanceId(Duration)

Consumer<K, V>.Assign(Collection<TopicPartition>)

Consumer<K, V>.Close()

Consumer<K, V>.Close(Duration)

Consumer<K, V>.CommitAsync()

Consumer<K, V>.CommitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)

Consumer<K, V>.CommitAsync(OffsetCommitCallback)

Consumer<K, V>.CommitSync()

Consumer<K, V>.CommitSync(Duration)

Consumer<K, V>.CommitSync(Map<TopicPartition, OffsetAndMetadata>, Duration)

Consumer<K, V>.CommitSync(Map<TopicPartition, OffsetAndMetadata>)

Consumer<K, V>.EnforceRebalance()

Consumer<K, V>.EnforceRebalance(String)

Consumer<K, V>.Pause(Collection<TopicPartition>)

Consumer<K, V>.Resume(Collection<TopicPartition>)

Consumer<K, V>.Seek(TopicPartition, long)

Consumer<K, V>.Seek(TopicPartition, OffsetAndMetadata)

Consumer<K, V>.SeekToBeginning(Collection<TopicPartition>)

Consumer<K, V>.SeekToEnd(Collection<TopicPartition>)

Consumer<K, V>.Subscribe(Collection<String>, ConsumerRebalanceListener)

Consumer<K, V>.Subscribe(Collection<String>)

Consumer<K, V>.Subscribe(Pattern, ConsumerRebalanceListener)

Consumer<K, V>.Subscribe(Pattern)

Consumer<K, V>.Unsubscribe()

Consumer<K, V>.Wakeup()

JVMBridgeBase<AutoCloseable>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute(Type, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<AutoCloseable>.SGetField(IJavaType, string)

JVMBridgeBase<AutoCloseable>.SGetField(string)

JVMBridgeBase<AutoCloseable>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<AutoCloseable>.SGetField<TReturn>(string)

JVMBridgeBase<AutoCloseable>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<AutoCloseable>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<AutoCloseable>.SSetField(IJavaType, string, object)

JVMBridgeBase<AutoCloseable>.SSetField(string, object)

JVMBridgeBase<AutoCloseable>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<AutoCloseable>.SSetField<TValue>(string, TValue)

JVMBridgeBase<AutoCloseable>.IsAssignableFrom(string)

JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)

JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()

JVMBridgeBase<AutoCloseable>.New(params object[])

JVMBridgeBase<AutoCloseable>.NewWithSignature(string, params object[])

JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])

JVMBridgeBase<AutoCloseable>.DynBridgeClazz

JVMBridgeBase<AutoCloseable>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.Dispose()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeListener

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Extension Methods

KafkaConsumerExtensions.ConsumeAsync<K, V>(IConsumer<K, V>)

KafkaConsumerExtensions.Consume<K, V>(IConsumer<K, V>, CancellationToken)

Constructors

MockConsumer()

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

public MockConsumer()

MockConsumer(OffsetResetStrategy)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#org.apache.kafka.clients.consumer.MockConsumer(org.apache.kafka.clients.consumer.OffsetResetStrategy)

public MockConsumer(OffsetResetStrategy arg0)

Parameters

arg0 OffsetResetStrategy

OffsetResetStrategy

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

Parameters

args object[]

Properties

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeCloseable.htm

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeInterface.htm

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeStatic.htm

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AddRecord(ConsumerRecord<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#addRecord-org.apache.kafka.clients.consumer.ConsumerRecord-

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

Parameters

arg0 ConsumerRecord<K, V>

ConsumerRecord

Assign(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#assign-java.util.Collection-

public void Assign(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Assignment()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#assignment--

public Set<TopicPartition> Assignment()

Returns

Set<TopicPartition>

Set

BeginningOffsets(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#beginningOffsets-java.util.Collection-

public Map<TopicPartition, Long> BeginningOffsets(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, Long>

Map

BeginningOffsets(Collection<TopicPartition>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#beginningOffsets-java.util.Collection-java.time.Duration-

public Map<TopicPartition, Long> BeginningOffsets(Collection<TopicPartition> arg0, Duration arg1)

Parameters

arg0 Collection<TopicPartition>

Collection

arg1 Duration

Duration

Returns

Map<TopicPartition, Long>

Map

ClientInstanceId(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.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/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#close--

public void Close()

Close(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#close-java.time.Duration-

public void Close(Duration arg0)

Parameters

arg0 Duration

Duration

Closed()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#closed--

public bool Closed()

Returns

bool

bool

CommitAsync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync--

public void CommitAsync()

CommitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync-java.util.Map-org.apache.kafka.clients.consumer.OffsetCommitCallback-

public void CommitAsync(Map<TopicPartition, OffsetAndMetadata> arg0, OffsetCommitCallback arg1)

Parameters

arg0 Map<TopicPartition, OffsetAndMetadata>

Map

arg1 OffsetCommitCallback

OffsetCommitCallback

CommitAsync(OffsetCommitCallback)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync-org.apache.kafka.clients.consumer.OffsetCommitCallback-

public void CommitAsync(OffsetCommitCallback arg0)

Parameters

arg0 OffsetCommitCallback

OffsetCommitCallback

CommitSync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitSync--

public void CommitSync()

CommitSync(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitSync-java.time.Duration-

public void CommitSync(Duration arg0)

Parameters

arg0 Duration

Duration

CommitSync(Map<TopicPartition, OffsetAndMetadata>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitSync-java.util.Map-

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

Parameters

arg0 Map<TopicPartition, OffsetAndMetadata>

Map

CommitSync(Map<TopicPartition, OffsetAndMetadata>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#commitSync-java.util.Map-java.time.Duration-

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

Parameters

arg0 Map<TopicPartition, OffsetAndMetadata>

Map

arg1 Duration

Duration

Committed(Set<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#committed-java.util.Set-

public Map<TopicPartition, OffsetAndMetadata> Committed(Set<TopicPartition> arg0)

Parameters

arg0 Set<TopicPartition>

Set

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

Committed(Set<TopicPartition>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#committed-java.util.Set-java.time.Duration-

public Map<TopicPartition, OffsetAndMetadata> Committed(Set<TopicPartition> arg0, Duration arg1)

Parameters

arg0 Set<TopicPartition>

Set

arg1 Duration

Duration

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

CurrentLag(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#currentLag-org.apache.kafka.common.TopicPartition-

public OptionalLong CurrentLag(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

OptionalLong

OptionalLong

DisableTelemetry()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#disableTelemetry--

public void DisableTelemetry()

EndOffsets(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#endOffsets-java.util.Collection-

public Map<TopicPartition, Long> EndOffsets(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, Long>

Map

EndOffsets(Collection<TopicPartition>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#endOffsets-java.util.Collection-java.time.Duration-

public Map<TopicPartition, Long> EndOffsets(Collection<TopicPartition> arg0, Duration arg1)

Parameters

arg0 Collection<TopicPartition>

Collection

arg1 Duration

Duration

Returns

Map<TopicPartition, Long>

Map

EnforceRebalance()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#enforceRebalance--

public void EnforceRebalance()

EnforceRebalance(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#enforceRebalance-java.lang.String-

public void EnforceRebalance(String arg0)

Parameters

arg0 String

String

GroupMetadata()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#groupMetadata--

public ConsumerGroupMetadata GroupMetadata()

Returns

ConsumerGroupMetadata

ConsumerGroupMetadata

InjectTimeoutException(int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#injectTimeoutException-int-

public void InjectTimeoutException(int arg0)

Parameters

arg0 int

int

LastPollTimeout()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#lastPollTimeout--

public Duration LastPollTimeout()

Returns

Duration

Duration

ListTopics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#listTopics--

public Map<String, List<PartitionInfo>> ListTopics()

Returns

Map<String, List<PartitionInfo>>

Map

ListTopics(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#listTopics-java.time.Duration-

public Map<String, List<PartitionInfo>> ListTopics(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Map<String, List<PartitionInfo>>

Map

Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.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

OffsetsForTimes(Map<TopicPartition, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#offsetsForTimes-java.util.Map-

public Map<TopicPartition, OffsetAndTimestamp> OffsetsForTimes(Map<TopicPartition, Long> arg0)

Parameters

arg0 Map<TopicPartition, Long>

Map

Returns

Map<TopicPartition, OffsetAndTimestamp>

Map

OffsetsForTimes(Map<TopicPartition, Long>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#offsetsForTimes-java.util.Map-java.time.Duration-

public Map<TopicPartition, OffsetAndTimestamp> OffsetsForTimes(Map<TopicPartition, Long> arg0, Duration arg1)

Parameters

arg0 Map<TopicPartition, Long>

Map

arg1 Duration

Duration

Returns

Map<TopicPartition, OffsetAndTimestamp>

Map

PartitionsFor(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#partitionsFor-java.lang.String-

public List<PartitionInfo> PartitionsFor(String arg0)

Parameters

arg0 String

String

Returns

List<PartitionInfo>

List

PartitionsFor(String, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#partitionsFor-java.lang.String-java.time.Duration-

public List<PartitionInfo> PartitionsFor(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

List<PartitionInfo>

List

Pause(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#pause-java.util.Collection-

public void Pause(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Paused()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#paused--

public Set<TopicPartition> Paused()

Returns

Set<TopicPartition>

Set

Poll(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#poll-java.time.Duration-

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

Parameters

arg0 Duration

Duration

Returns

ConsumerRecords<K, V>

ConsumerRecords

Position(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#position-org.apache.kafka.common.TopicPartition-

public long Position(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

long

long

Position(TopicPartition, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#position-org.apache.kafka.common.TopicPartition-java.time.Duration-

public long Position(TopicPartition arg0, Duration arg1)

Parameters

arg0 TopicPartition

TopicPartition

arg1 Duration

Duration

Returns

long

long

Rebalance(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#rebalance-java.util.Collection-

public void Rebalance(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

ResetShouldRebalance()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#resetShouldRebalance--

public void ResetShouldRebalance()

Resume(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#resume-java.util.Collection-

public void Resume(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

ScheduleNopPollTask()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#scheduleNopPollTask--

public void ScheduleNopPollTask()

SchedulePollTask(Runnable)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#schedulePollTask-java.lang.Runnable-

public void SchedulePollTask(Runnable arg0)

Parameters

arg0 Runnable

Runnable

Seek(TopicPartition, OffsetAndMetadata)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#seek-org.apache.kafka.common.TopicPartition-org.apache.kafka.clients.consumer.OffsetAndMetadata-

public void Seek(TopicPartition arg0, OffsetAndMetadata arg1)

Parameters

arg0 TopicPartition

TopicPartition

arg1 OffsetAndMetadata

OffsetAndMetadata

Seek(TopicPartition, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#seek-org.apache.kafka.common.TopicPartition-long-

public void Seek(TopicPartition arg0, long arg1)

Parameters

arg0 TopicPartition

TopicPartition

arg1 long

long

SeekToBeginning(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#seekToBeginning-java.util.Collection-

public void SeekToBeginning(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

SeekToEnd(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#seekToEnd-java.util.Collection-

public void SeekToEnd(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

SetClientInstanceId(Uuid)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#setClientInstanceId-org.apache.kafka.common.Uuid-

public void SetClientInstanceId(Uuid arg0)

Parameters

arg0 Uuid

Uuid

SetOffsetsException(JVMBridgeException)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#setOffsetsException-org.apache.kafka.common.KafkaException-

public void SetOffsetsException(JVMBridgeException arg0)

Parameters

arg0 JVMBridgeException

KafkaException

SetPollException(JVMBridgeException)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#setPollException-org.apache.kafka.common.KafkaException-

public void SetPollException(JVMBridgeException arg0)

Parameters

arg0 JVMBridgeException

KafkaException

ShouldRebalance()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#shouldRebalance--

public bool ShouldRebalance()

Returns

bool

bool

Subscribe(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#subscribe-java.util.Collection-

public void Subscribe(Collection<String> arg0)

Parameters

arg0 Collection<String>

Collection

Subscribe(Collection<String>, ConsumerRebalanceListener)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#subscribe-java.util.Collection-org.apache.kafka.clients.consumer.ConsumerRebalanceListener-

public void Subscribe(Collection<String> arg0, ConsumerRebalanceListener arg1)

Parameters

arg0 Collection<String>

Collection

arg1 ConsumerRebalanceListener

ConsumerRebalanceListener

Subscribe(Pattern)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#subscribe-java.util.regex.Pattern-

public void Subscribe(Pattern arg0)

Parameters

arg0 Pattern

Pattern

Subscribe(Pattern, ConsumerRebalanceListener)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#subscribe-java.util.regex.Pattern-org.apache.kafka.clients.consumer.ConsumerRebalanceListener-

public void Subscribe(Pattern arg0, ConsumerRebalanceListener arg1)

Parameters

arg0 Pattern

Pattern

arg1 ConsumerRebalanceListener

ConsumerRebalanceListener

Subscription()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#subscription--

public Set<String> Subscription()

Returns

Set<String>

Set

Unsubscribe()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#unsubscribe--

public void Unsubscribe()

UpdateBeginningOffsets(Map<TopicPartition, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#updateBeginningOffsets-java.util.Map-

public void UpdateBeginningOffsets(Map<TopicPartition, Long> arg0)

Parameters

arg0 Map<TopicPartition, Long>

Map

UpdateEndOffsets(Map<TopicPartition, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#updateEndOffsets-java.util.Map-

public void UpdateEndOffsets(Map<TopicPartition, Long> arg0)

Parameters

arg0 Map<TopicPartition, Long>

Map

UpdatePartitions(String, List<PartitionInfo>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#updatePartitions-java.lang.String-java.util.List-

public void UpdatePartitions(String arg0, List<PartitionInfo> arg1)

Parameters

arg0 String

String

arg1 List<PartitionInfo>

List

Wakeup()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/MockConsumer.html#wakeup--

public void Wakeup()

Operators

implicit operator MockConsumer(MockConsumer<K, V>)

Converter from MockConsumer<K, V> to MockConsumer

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

Parameters

t MockConsumer<K, V>

Returns

MockConsumer