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

public class ConsumerRecord<K, V> : JVMBridgeBase<ConsumerRecord<K, V>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Type Parameters

K

V

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<ConsumerRecord<K, V>>

ConsumerRecord<K, V>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

ConsumerRecord(String, int, long, long, TimestampType, int, int, K, V, Headers, Optional<Integer>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecord.html#%3Cinit%3E(java.lang.String,int,long,long,org.apache.kafka.common.record.TimestampType,int,int,java.lang.Object,java.lang.Object,org.apache.kafka.common.header.Headers,java.util.Optional)

public ConsumerRecord(String arg0, int arg1, long arg2, long arg3, TimestampType arg4, int arg5, int arg6, K arg7, V arg8, Headers arg9, Optional<Integer> arg10)

Parameters

arg0 String

String

arg1 int

int

arg2 long

long

arg3 long

long

arg4 TimestampType

TimestampType

arg5 int

int

arg6 int

int

arg7 K

K

arg8 V

V

arg9 Headers

Headers

arg10 Optional<Integer>

Optional

ConsumerRecord(String, int, long, long, TimestampType, int, int, K, V, Headers, Optional<Integer>, Optional<Short>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecord.html#%3Cinit%3E(java.lang.String,int,long,long,org.apache.kafka.common.record.TimestampType,int,int,java.lang.Object,java.lang.Object,org.apache.kafka.common.header.Headers,java.util.Optional,java.util.Optional)

public ConsumerRecord(String arg0, int arg1, long arg2, long arg3, TimestampType arg4, int arg5, int arg6, K arg7, V arg8, Headers arg9, Optional<Integer> arg10, Optional<Short> arg11)

Parameters

arg0 String

String

arg1 int

int

arg2 long

long

arg3 long

long

arg4 TimestampType

TimestampType

arg5 int

int

arg6 int

int

arg7 K

K

arg8 V

V

arg9 Headers

Headers

arg10 Optional<Integer>

Optional

arg11 Optional<Short>

Optional

ConsumerRecord(String, int, long, K, V)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecord.html#%3Cinit%3E(java.lang.String,int,long,java.lang.Object,java.lang.Object)

public ConsumerRecord(String arg0, int arg1, long arg2, K arg3, V arg4)

Parameters

arg0 String

String

arg1 int

int

arg2 long

long

arg3 K

K

arg4 V

V

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

Parameters

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

DateTime

DateTime of Timestamp()

public DateTime DateTime { get; }

Property Value

DateTime

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

NO_TIMESTAMP

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

public static long NO_TIMESTAMP { get; set; }

Property Value

long

NULL_SIZE

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

public static int NULL_SIZE { get; set; }

Property Value

int

Methods

CreatePoolableInstance(String, int, long, long, TimestampType, int, int, K, V, Headers, Optional<Integer>)

HPA initializer for ConsumerRecord(Java.Lang.String arg0, int arg1, long arg2, long arg3, Org.Apache.Kafka.Common.Record.TimestampType arg4, int arg5, int arg6, K arg7, V arg8, Org.Apache.Kafka.Common.Header.Headers arg9, Java.Util.Optional%3CJava.Lang.Integer%3E arg10)

public static ConsumerRecord<K, V> CreatePoolableInstance(String arg0, int arg1, long arg2, long arg3, TimestampType arg4, int arg5, int arg6, K arg7, V arg8, Headers arg9, Optional<Integer> arg10)

Parameters

arg0 String

arg1 int

arg2 long

arg3 long

arg4 TimestampType

arg5 int

arg6 int

arg7 K

arg8 V

arg9 Headers

arg10 Optional<Integer>

Returns

ConsumerRecord<K, V>

CreatePoolableInstance(String, int, long, long, TimestampType, int, int, K, V, Headers, Optional<Integer>, Optional<Short>)

HPA initializer for ConsumerRecord(Java.Lang.String arg0, int arg1, long arg2, long arg3, Org.Apache.Kafka.Common.Record.TimestampType arg4, int arg5, int arg6, K arg7, V arg8, Org.Apache.Kafka.Common.Header.Headers arg9, Java.Util.Optional%3CJava.Lang.Integer%3E arg10, Java.Util.Optional%3CJava.Lang.Short%3E arg11)

public static ConsumerRecord<K, V> CreatePoolableInstance(String arg0, int arg1, long arg2, long arg3, TimestampType arg4, int arg5, int arg6, K arg7, V arg8, Headers arg9, Optional<Integer> arg10, Optional<Short> arg11)

Parameters

arg0 String

arg1 int

arg2 long

arg3 long

arg4 TimestampType

arg5 int

arg6 int

arg7 K

arg8 V

arg9 Headers

arg10 Optional<Integer>

arg11 Optional<Short>

Returns

ConsumerRecord<K, V>

CreatePoolableInstance(String, int, long, K, V)

HPA initializer for ConsumerRecord(Java.Lang.String arg0, int arg1, long arg2, K arg3, V arg4)

public static ConsumerRecord<K, V> CreatePoolableInstance(String arg0, int arg1, long arg2, K arg3, V arg4)

Parameters

arg0 String

arg1 int

arg2 long

arg3 K

arg4 V

Returns

ConsumerRecord<K, V>

DeliveryCount()

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

public Optional<Short> DeliveryCount()

Returns

Optional<Short>

Optional

Headers()

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

public Headers Headers()

Returns

Headers

Headers

Key()

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

public K Key()

Returns

K

K

LeaderEpoch()

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

public Optional<Integer> LeaderEpoch()

Returns

Optional<Integer>

Optional

Offset()

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

public long Offset()

Returns

long

long

Partition()

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

public int Partition()

Returns

int

int

SerializedKeySize()

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

public int SerializedKeySize()

Returns

int

int

SerializedValueSize()

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

public int SerializedValueSize()

Returns

int

int

Timestamp()

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

public long Timestamp()

Returns

long

long

TimestampType()

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

public TimestampType TimestampType()

Returns

TimestampType

TimestampType

Topic()

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

public String Topic()

Returns

String

String

Value()

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

public V Value()

Returns

V

V

Operators

implicit operator ConsumerRecord(ConsumerRecord<K, V>)

Converter from ConsumerRecord<K, V> to ConsumerRecord

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

Parameters

t ConsumerRecord<K, V>

Returns

ConsumerRecord