Class ProducerRecord<K, V>

Namespace

MASES.KNet.Producer

Assembly

MASES.KNet.dll

Extends ProducerRecord<K, V, TJVMK, TJVMV> using array of byte

public class ProducerRecord<K, V> : ProducerRecord<K, V, byte[], byte[]>

Type Parameters

K

The key type

V

The value type

Inheritance

object

ProducerRecord<K, V, byte[], byte[]>

ProducerRecord<K, V>

Inherited Members

ProducerRecord<K, V, byte[], byte[]>.Topic

ProducerRecord<K, V, byte[], byte[]>.Partition

ProducerRecord<K, V, byte[], byte[]>.Key

ProducerRecord<K, V, byte[], byte[]>.Value

ProducerRecord<K, V, byte[], byte[]>.Timestamp

ProducerRecord<K, V, byte[], byte[]>.DateTime

ProducerRecord<K, V, byte[], byte[]>.Headers

ProducerRecord<K, V, byte[], byte[]>.ToString()

object.ToString()

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