Class ProducerRecordBuffered<K, V>

Namespace

MASES.KNet.Producer

Assembly

MASES.KNet.dll

Extends ProducerRecord<K, V, TJVMK, TJVMV> using ByteBuffer

public class ProducerRecordBuffered<K, V> : ProducerRecord<K, V, ByteBuffer, ByteBuffer>

Type Parameters

K

The key type

V

The value type

Inheritance

object

ProducerRecord<K, V, ByteBuffer, ByteBuffer>

ProducerRecordBuffered<K, V>

Inherited Members

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.Topic

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.Partition

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.Key

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.Value

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.Timestamp

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.DateTime

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.Headers

ProducerRecord<K, V, ByteBuffer, ByteBuffer>.ToString()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Constructors

ProducerRecordBuffered()

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

public ProducerRecordBuffered()

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

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

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

Parameters

topic string

partition int

timestamp DateTime

key K

value V

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

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

public ProducerRecordBuffered(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

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

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

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

Parameters

topic string

partition int

timestamp long

key K

value V

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

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

public ProducerRecordBuffered(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

ProducerRecordBuffered(string, int, K, V)

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

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

Parameters

topic string

partition int

key K

value V

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

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

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

Parameters

topic string

partition int

key K

value V

headers Headers

ProducerRecordBuffered(string, K, V)

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

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

Parameters

topic string

key K

value V

ProducerRecordBuffered(string, V)

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

public ProducerRecordBuffered(string topic, V value)

Parameters

topic string

value V