Class KNetProducerKeyBuffered<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 ByteBuffer for key

public class KNetProducerKeyBuffered<K, V> : KNetProducer<K, V, ByteBuffer, byte[]>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IJVMBridgeBaseStatic, IProducer<K, V, ByteBuffer, byte[]>, IProducer<ByteBuffer, 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<ByteBuffer, byte[]>

KafkaProducer<ByteBuffer, byte[]>

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

KNetProducerKeyBuffered<K, V>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IJVMBridgeBaseStatic

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

IProducer<ByteBuffer, byte[]>

IProducer

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IDisposable

ICloseable

IAutoCloseable

Inherited Members

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

KafkaProducer<ByteBuffer, byte[]>.BridgeClassName

KafkaProducer<ByteBuffer, byte[]>.IsBridgeAbstract

KafkaProducer<ByteBuffer, byte[]>.IsBridgeCloseable

KafkaProducer<ByteBuffer, byte[]>.IsBridgeInterface

KafkaProducer<ByteBuffer, byte[]>.IsBridgeStatic

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

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

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

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

KafkaProducer<ByteBuffer, byte[]>.NETWORK_THREAD_PREFIX

KafkaProducer<ByteBuffer, byte[]>.PRODUCER_METRIC_GROUP_NAME

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

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

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

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

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

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

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

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

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

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

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

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

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

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

KafkaProducer<ByteBuffer, 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

KNetProducerKeyBuffered(ProducerConfigBuilder)

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

public KNetProducerKeyBuffered(ProducerConfigBuilder configBuilder)

Parameters

configBuilder ProducerConfigBuilder

An instance of ProducerConfigBuilder

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

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

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

Parameters

props ProducerConfigBuilder

The properties to use, see ProducerConfigBuilder

keySerializer ISerDes<K, ByteBuffer>

Key serializer base on SerDes<T, TJVMT>

valueSerializer ISerDes<V, byte[]>

Value serializer base on SerDes<T, TJVMT>