Class KNetProducer<K, V>

Namespace

MASES.KNet.Producer

Assembly

MASES.KNet.dll

Extends KafkaProducer adding less intrusive methods which performs better in high throughput applications, extends KNetProducer<K, V, TJVMK, TJVMV> using array of byte

public class KNetProducer<K, V> : KNetProducer<K, V, byte[], byte[]>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IJVMBridgeBaseStatic, IProducer<K, V, byte[], byte[]>, IProducer<byte[], byte[]>, IProducer, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

Same meaning of KafkaProducer

V

Same meaning of KafkaProducer

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AutoCloseable>

AutoCloseable

Closeable

Producer<byte[], byte[]>

KafkaProducer<byte[], byte[]>

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

KNetProducer<K, V>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IJVMBridgeBaseStatic

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

IProducer<byte[], byte[]>

IProducer

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IDisposable

ICloseable

IAutoCloseable

Inherited Members

KNetProducer<K, V, byte[], byte[]>.BridgeClassName

KNetProducer<K, V, byte[], byte[]>.Dispose(bool)

KNetProducer<K, V, byte[], byte[]>.SetCallback(Callback)

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

KNetProducer<K, V, byte[], byte[]>.Send(ProducerRecord<K, V, byte[], byte[]>, Callback)

KNetProducer<K, V, byte[], byte[]>.Send(string, int?, long?, K, V, Headers)

KNetProducer<K, V, byte[], byte[]>.Send(string, int?, long?, K, V)

KNetProducer<K, V, byte[], byte[]>.Send(string, int?, K, V, Headers)

KNetProducer<K, V, byte[], byte[]>.Send(string, int?, K, V)

KNetProducer<K, V, byte[], byte[]>.Send(string, K, V)

KNetProducer<K, V, byte[], byte[]>.Send(string, V)

KNetProducer<K, V, byte[], byte[]>.Produce(string, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.Produce(string, int?, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.Produce(string, int?, long?, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.Produce(string, int?, DateTime?, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.Produce(ProducerRecord<K, V, byte[], byte[]>, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.Produce(string, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.ProduceAndWait(string, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.Produce(string, int?, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.ProduceAndWait(string, int?, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.Produce(string, int?, long?, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.ProduceAndWait(string, int?, long?, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.Produce(string, int?, DateTime?, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.ProduceAndWait(string, int?, DateTime?, K, V, Callback)

KNetProducer<K, V, byte[], byte[]>.Produce(ProducerRecord<K, V, byte[], byte[]>, Callback)

KNetProducer<K, V, byte[], byte[]>.ProduceAndWait(ProducerRecord<K, V, byte[], byte[]>, Callback)

KNetProducer<K, V, byte[], byte[]>.ProduceAsync(string, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.ProduceAsync(string, int?, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.ProduceAsync(string, int?, long?, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.ProduceAsync(string, int?, DateTime?, K, V, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.ProduceAsync(ProducerRecord<K, V, byte[], byte[]>, Action<RecordMetadata, JVMBridgeException>)

KNetProducer<K, V, byte[], byte[]>.NewRecord()

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, int?, long?, K, V, Headers)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, int?, DateTime?, K, V, Headers)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, int?, long?, K, V)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, int?, DateTime?, K, V)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, int?, K, V, Headers)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, int?, K, V)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, K, V)

KNetProducer<K, V, byte[], byte[]>.NewRecord(string, V)

KafkaProducer<byte[], byte[]>.BridgeClassName

KafkaProducer<byte[], byte[]>.IsBridgeAbstract

KafkaProducer<byte[], byte[]>.IsBridgeCloseable

KafkaProducer<byte[], byte[]>.IsBridgeInterface

KafkaProducer<byte[], byte[]>.IsBridgeStatic

KafkaProducer<byte[], byte[]>.CreatePoolableInstance(Map<String, object>, Serializer<byte[]>, Serializer<byte[]>)

KafkaProducer<byte[], byte[]>.CreatePoolableInstance(Map<String, object>)

KafkaProducer<byte[], byte[]>.CreatePoolableInstance(Properties, Serializer<byte[]>, Serializer<byte[]>)

KafkaProducer<byte[], byte[]>.CreatePoolableInstance(Properties)

KafkaProducer<byte[], byte[]>.NETWORK_THREAD_PREFIX

KafkaProducer<byte[], byte[]>.PRODUCER_METRIC_GROUP_NAME

KafkaProducer<byte[], byte[]>.Send(ProducerRecord<byte[], byte[]>, Callback)

KafkaProducer<byte[], byte[]>.Send(ProducerRecord<byte[], byte[]>)

KafkaProducer<byte[], byte[]>.PartitionsFor(String)

KafkaProducer<byte[], byte[]>.Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

KafkaProducer<byte[], byte[]>.ClientInstanceId(Duration)

KafkaProducer<byte[], byte[]>.AbortTransaction()

KafkaProducer<byte[], byte[]>.BeginTransaction()

KafkaProducer<byte[], byte[]>.Close()

KafkaProducer<byte[], byte[]>.Close(Duration)

KafkaProducer<byte[], byte[]>.CommitTransaction()

KafkaProducer<byte[], byte[]>.Flush()

KafkaProducer<byte[], byte[]>.InitTransactions()

KafkaProducer<byte[], byte[]>.RegisterMetricForSubscription(KafkaMetric)

KafkaProducer<byte[], byte[]>.SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata)

KafkaProducer<byte[], byte[]>.UnregisterMetricFromSubscription(KafkaMetric)

Extension Methods

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

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, 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, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, long, 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, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, 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, 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>)

Constructors

KNetProducer(ProducerConfigBuilder)

Initialize a new instance of KNetProducer<K, V, TJVMK, TJVMV>

public KNetProducer(ProducerConfigBuilder configBuilder)

Parameters

configBuilder ProducerConfigBuilder

An instance of ProducerConfigBuilder

KNetProducer(ProducerConfigBuilder, ISerDes<K, byte[]>, ISerDes<V, byte[]>)

Initialize a new instance of KNetProducer<K, V, TJVMK, TJVMV>

public KNetProducer(ProducerConfigBuilder props, ISerDes<K, byte[]> keySerializer, ISerDes<V, byte[]> valueSerializer)

Parameters

props ProducerConfigBuilder

The properties to use, see ProducerConfigBuilder

keySerializer ISerDes<K, byte[]>

Key serializer base on SerDes<T, TJVMT>

valueSerializer ISerDes<V, byte[]>

Value serializer base on SerDes<T, TJVMT>