Class ConsumerRecord<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Consumer

Assembly

MASES.KNet.dll

KNet extension of ConsumerRecord<K, V>

public class ConsumerRecord<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

ConsumerRecord<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

DateTime

DateTime of Timestamp()

public DateTime DateTime { get; }

Property Value

DateTime

Headers

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

public Headers Headers { get; }

Property Value

Headers

Headers

Key

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

public K Key { get; }

Property Value

K

K

LeaderEpoch

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

public int? LeaderEpoch { get; }

Property Value

int?

Optional

Offset

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

public long Offset { get; }

Property Value

long

long

Partition

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

public int Partition { get; }

Property Value

int

int

SerializedKeySize

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

public int SerializedKeySize { get; }

Property Value

int

int

SerializedValueSize

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

public int SerializedValueSize { get; }

Property Value

int

int

Timestamp

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

public long Timestamp { get; }

Property Value

long

long

TimestampType

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

public TimestampType TimestampType { get; }

Property Value

TimestampType

TimestampType

Topic

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

public string Topic { get; }

Property Value

string

String

Value

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

public V Value { get; }

Property Value

V

V

Methods

ToString()

Returns a string that represents the current object.

public override string ToString()

Returns

string

A string that represents the current object.