Class ConsumerRecords

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/ConsumerRecords.html

public class ConsumerRecords : Iterable, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IEnumerable, IEnumerableExtension, IIterable

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<Iterable>

JVMBridgeBaseEnumerable<Iterable>

Iterable

ConsumerRecords

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IEnumerable

IEnumerableExtension

IIterable

Constructors

ConsumerRecords(Map)

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

[Obsolete("Deprecated in JVM")]
public ConsumerRecords(Map arg0)

Parameters

arg0 Map

Map

ConsumerRecords(Map, Map)

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

public ConsumerRecords(Map arg0, Map arg1)

Parameters

arg0 Map

Map

arg1 Map

Map

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

Parameters

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

EMPTY

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

public static ConsumerRecords EMPTY { get; set; }

Property Value

ConsumerRecords

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

Count()

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

public int Count()

Returns

int

int

CreatePoolableInstance(Map)

HPA initializer for ConsumerRecords(Java.Util.Map arg0)

public static ConsumerRecords CreatePoolableInstance(Map arg0)

Parameters

arg0 Map

Returns

ConsumerRecords

CreatePoolableInstance(Map, Map)

HPA initializer for ConsumerRecords(Java.Util.Map arg0, Java.Util.Map arg1)

public static ConsumerRecords CreatePoolableInstance(Map arg0, Map arg1)

Parameters

arg0 Map

arg1 Map

Returns

ConsumerRecords

Empty()

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

public static ConsumerRecords Empty()

Returns

ConsumerRecords

ConsumerRecords

IsEmpty()

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

public bool IsEmpty()

Returns

bool

bool

Iterator()

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

public Iterator Iterator()

Returns

Iterator

Iterator

NextOffsets()

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

public Map NextOffsets()

Returns

Map

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 Partitions()

Returns

Set

Set

Records(String)

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 Records(String arg0)

Parameters

arg0 String

String

Returns

Iterable

Iterable

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 Records(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

List

List