Class ProducerRecord<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Producer

Assembly

MASES.KNet.dll

KNet extension of ProducerRecord<K, V>

public class ProducerRecord<K, V, TJVMK, TJVMV>

Type Parameters

K

V

TJVMK

TJVMV

Inheritance

object

ProducerRecord<K, V, TJVMK, TJVMV>

Derived

ProducerRecordBuffered<K, V>

ProducerRecord<K, V>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Constructors

ProducerRecord()

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord()

ProducerRecord(string, int, DateTime, K, V)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, int partition, DateTime timestamp, K key, V value)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

ProducerRecord(string, int, DateTime, K, V, Headers)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, int partition, DateTime timestamp, K key, V value, Headers headers)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

headers Headers

ProducerRecord(string, int, long, K, V)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, int partition, long timestamp, K key, V value)

Parameters

topic string

partition int

timestamp long

key K

value V

ProducerRecord(string, int, long, K, V, Headers)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, int partition, long timestamp, K key, V value, Headers headers)

Parameters

topic string

partition int

timestamp long

key K

value V

headers Headers

ProducerRecord(string, int, K, V)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, int partition, K key, V value)

Parameters

topic string

partition int

key K

value V

ProducerRecord(string, int, K, V, Headers)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, int partition, K key, V value, Headers headers)

Parameters

topic string

partition int

key K

value V

headers Headers

ProducerRecord(string, K, V)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, K key, V value)

Parameters

topic string

key K

value V

ProducerRecord(string, V)

Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>

public ProducerRecord(string topic, V value)

Parameters

topic string

value V

Properties

DateTime

DateTime of Timestamp()

public DateTime? DateTime { get; }

Property Value

DateTime?

Headers

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/producer/ProducerRecord.html#headers()

public Headers Headers { get; }

Property Value

Headers

Headers

Key

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/producer/ProducerRecord.html#key()

public K Key { get; }

Property Value

K

K

Partition

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/producer/ProducerRecord.html#partition()

public int? Partition { get; }

Property Value

int?

Integer

Timestamp

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/producer/ProducerRecord.html#timestamp()

public long? Timestamp { get; }

Property Value

long?

Long

Topic

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/producer/ProducerRecord.html#topic()

public string Topic { get; }

Property Value

string

String

Value

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/producer/ProducerRecord.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.