Class ConsumerRecords<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Consumer

Assembly

MASES.KNet.dll

KNet extension of ConsumerRecords<K, V>

public class ConsumerRecords<K, V, TJVMK, TJVMV> : IKNetInnerReference<ConsumerRecords<TJVMK, TJVMV>>, IEnumerable<ConsumerRecord<K, V, TJVMK, TJVMV>>, IEnumerable, IAsyncEnumerable<ConsumerRecord<K, V, TJVMK, TJVMV>>, IDisposable

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

ConsumerRecords<K, V, TJVMK, TJVMV>

Implements

IKNetInnerReference<ConsumerRecords<TJVMK, TJVMV>>

IEnumerable<ConsumerRecord<K, V, TJVMK, TJVMV>>

IEnumerable

IAsyncEnumerable<ConsumerRecord<K, V, TJVMK, TJVMV>>

IDisposable

Properties

Count

The number of elements in ConsumerRecords<K, V, TJVMK, TJVMV>

public int Count { get; }

Property Value

int

InnerReference

The underlying inner reference used from KNet object instance

public ConsumerRecords<TJVMK, TJVMV> InnerReference { get; }

Property Value

ConsumerRecords<TJVMK, TJVMV>

IsEmpty

true if the ConsumerRecords<K, V, TJVMK, TJVMV> is empty

public bool IsEmpty { get; }

Property Value

bool

NextOffsets

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

public Map<TopicPartition, OffsetAndMetadata> NextOffsets { get; }

Property Value

Map<TopicPartition, OffsetAndMetadata>

Map

Partitions

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

public Set<TopicPartition> Partitions { get; }

Property Value

Set<TopicPartition>

Set

Methods

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Dispose(bool)

Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

The disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)

Records(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecords.html#records(org.apache.kafka.common.TopicPartition)

public List<ConsumerRecord<TJVMK, TJVMV>> Records(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

List<ConsumerRecord<TJVMK, TJVMV>>

List

Records(string)

Extension of https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecords.html#records(java.lang.String)

public Iterable<ConsumerRecord<TJVMK, TJVMV>> Records(string arg0)

Parameters

arg0 string

string

Returns

Iterable<ConsumerRecord<TJVMK, TJVMV>>

Iterable of