Interface IProducer<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Producer

Assembly

MASES.KNet.dll

Extends IProducer<K, V> adding less intrusive methods which performs better in high throughput applications

public interface IProducer<K, V, TJVMK, TJVMV> : IProducer<TJVMK, TJVMV>, IProducer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

Same meaning of IProducer<K, V>

V

Same meaning of IProducer<K, V>

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inherited Members

IProducer<TJVMK, TJVMV>.Send(ProducerRecord<TJVMK, TJVMV>)

IProducer<TJVMK, TJVMV>.Send(ProducerRecord<TJVMK, TJVMV>, Callback)

IProducer.InitTransactions()

IProducer.BeginTransaction()

IProducer.SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata)

IProducer.CommitTransaction()

IProducer.AbortTransaction()

IProducer.Flush()

IProducer.PartitionsFor(String)

IProducer.Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

IProducer.ClientInstanceId(Duration)

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

IDisposable.Dispose()

ICloseable.Close()

Extension Methods

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, ProducerRecord<K, V>, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, ProducerRecord<K, V>, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, ProducerRecord<K, V>, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, DateTime, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, long, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, K, V, Action<RecordMetadata, JVMBridgeException>)

Methods

NewRecord()

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord()

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

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

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, DateTime timestamp, K key, V value)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

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

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(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

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

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

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, long timestamp, K key, V value)

Parameters

topic string

partition int

timestamp long

key K

value V

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

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

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(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

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

NewRecord(string, int, K, V)

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, K key, V value)

Parameters

topic string

partition int

key K

value V

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

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

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, K key, V value, Headers headers)

Parameters

topic string

partition int

key K

value V

headers Headers

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

NewRecord(string, K, V)

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, K key, V value)

Parameters

topic string

key K

value V

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

NewRecord(string, V)

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

ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, V value)

Parameters

topic string

value V

Returns

ProducerRecord<K, V, TJVMK, TJVMV>

Produce(ProducerRecord<K, V, TJVMK, TJVMV>, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

Future<RecordMetadata> Produce(ProducerRecord<K, V, TJVMK, TJVMV> record, Callback cb = null)

Parameters

record ProducerRecord<K, V, TJVMK, TJVMV>

cb Callback

Returns

Future<RecordMetadata>

Produce(ProducerRecord<K, V, TJVMK, TJVMV>, Action<RecordMetadata, JVMBridgeException>)

KNet version of Send(ProducerRecord<K, V>, Callback)

void Produce(ProducerRecord<K, V, TJVMK, TJVMV> record, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

record ProducerRecord<K, V, TJVMK, TJVMV>

action Action<RecordMetadata, JVMBridgeException>

Produce(string, int, DateTime, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

Future<RecordMetadata> Produce(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

cb Callback

Returns

Future<RecordMetadata>

Produce(string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet version of Send(ProducerRecord<K, V>, Callback)

void Produce(string topic, int partition, DateTime timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Produce(string, int, long, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

Future<RecordMetadata> Produce(string topic, int partition, long timestamp, K key, V value, Callback cb = null)

Parameters

topic string

partition int

timestamp long

key K

value V

cb Callback

Returns

Future<RecordMetadata>

Produce(string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet version of Send(ProducerRecord<K, V>, Callback)

void Produce(string topic, int partition, long timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

partition int

timestamp long

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Produce(string, int, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

Future<RecordMetadata> Produce(string topic, int partition, K key, V value, Callback cb = null)

Parameters

topic string

partition int

key K

value V

cb Callback

Returns

Future<RecordMetadata>

Produce(string, int, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet version of Send(ProducerRecord<K, V>, Callback)

void Produce(string topic, int partition, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

partition int

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Produce(string, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

Future<RecordMetadata> Produce(string topic, K key, V value, Callback cb = null)

Parameters

topic string

key K

value V

cb Callback

Returns

Future<RecordMetadata>

Produce(string, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet version of Send(ProducerRecord<K, V>, Callback)

void Produce(string topic, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

key K

value V

action Action<RecordMetadata, JVMBridgeException>

ProduceAndWait(ProducerRecord<K, V, TJVMK, TJVMV>, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

void ProduceAndWait(ProducerRecord<K, V, TJVMK, TJVMV> record, Callback cb = null)

Parameters

record ProducerRecord<K, V, TJVMK, TJVMV>

cb Callback

ProduceAndWait(string, int, DateTime, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

void ProduceAndWait(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

cb Callback

ProduceAndWait(string, int, long, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

void ProduceAndWait(string topic, int partition, long timestamp, K key, V value, Callback cb = null)

Parameters

topic string

partition int

timestamp long

key K

value V

cb Callback

ProduceAndWait(string, int, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

void ProduceAndWait(string topic, int partition, K key, V value, Callback cb = null)

Parameters

topic string

partition int

key K

value V

cb Callback

ProduceAndWait(string, K, V, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

void ProduceAndWait(string topic, K key, V value, Callback cb = null)

Parameters

topic string

key K

value V

cb Callback

ProduceAsync(ProducerRecord<K, V, TJVMK, TJVMV>, Action<RecordMetadata, JVMBridgeException>)

KNet async version of Send(ProducerRecord<K, V>, Callback)

Task ProduceAsync(ProducerRecord<K, V, TJVMK, TJVMV> record, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

record ProducerRecord<K, V, TJVMK, TJVMV>

action Action<RecordMetadata, JVMBridgeException>

Returns

Task

ProduceAsync(string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet async version of Send(ProducerRecord<K, V>, Callback)

Task ProduceAsync(string topic, int partition, DateTime timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

partition int

timestamp DateTime

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Returns

Task

ProduceAsync(string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet async version of Send(ProducerRecord<K, V>, Callback)

Task ProduceAsync(string topic, int partition, long timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

partition int

timestamp long

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Returns

Task

ProduceAsync(string, int, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet async version of Send(ProducerRecord<K, V>, Callback)

Task ProduceAsync(string topic, int partition, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

partition int

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Returns

Task

ProduceAsync(string, K, V, Action<RecordMetadata, JVMBridgeException>)

KNet async version of Send(ProducerRecord<K, V>, Callback)

Task ProduceAsync(string topic, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)

Parameters

topic string

key K

value V

action Action<RecordMetadata, JVMBridgeException>

Returns

Task

Send(ProducerRecord<K, V, TJVMK, TJVMV>)

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(ProducerRecord<K, V, TJVMK, TJVMV> record)

Parameters

record ProducerRecord<K, V, TJVMK, TJVMV>

Returns

Future<RecordMetadata>

Send(ProducerRecord<K, V, TJVMK, TJVMV>, Callback)

KNet version of Send(ProducerRecord<K, V>, Callback)

Future<RecordMetadata> Send(ProducerRecord<K, V, TJVMK, TJVMV> record, Callback callback)

Parameters

record ProducerRecord<K, V, TJVMK, TJVMV>

callback Callback

Returns

Future<RecordMetadata>

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

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(string topic, int partition, long timestamp, K key, V value)

Parameters

topic string

partition int

timestamp long

key K

value V

Returns

Future<RecordMetadata>

Remarks

Supports only TJVMK and TJVMV based on byte arrays or ByteBuffer

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

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(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

Returns

Future<RecordMetadata>

Remarks

Supports only TJVMK and TJVMV based on byte arrays or ByteBuffer

Send(string, int, K, V)

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(string topic, int partition, K key, V value)

Parameters

topic string

partition int

key K

value V

Returns

Future<RecordMetadata>

Remarks

Supports only TJVMK and TJVMV based on byte arrays or ByteBuffer

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

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(string topic, int partition, K key, V value, Headers headers)

Parameters

topic string

partition int

key K

value V

headers Headers

Returns

Future<RecordMetadata>

Remarks

Supports only TJVMK and TJVMV based on byte arrays or ByteBuffer

Send(string, K, V)

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(string topic, K key, V value)

Parameters

topic string

key K

value V

Returns

Future<RecordMetadata>

Remarks

Supports only TJVMK and TJVMV based on byte arrays or ByteBuffer

Send(string, V)

KNet version of Send(ProducerRecord<K, V>)

Future<RecordMetadata> Send(string topic, V value)

Parameters

topic string

value V

Returns

Future<RecordMetadata>

Remarks

Supports only TJVMK and TJVMV based on byte arrays or ByteBuffer

SetCallback(Callback)

Set Callback into instance of IProducer<K, V>

void SetCallback(Callback callback)

Parameters

callback Callback

The Callback