Table of Contents

Namespace MASES.KNet.Producer

Classes

KNetProducerBuffered<K, V>

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

KNetProducerKeyBuffered<K, V>

Extends KafkaProducer adding less intrusive methods which performs better in high throughput applications, extends KNetProducer<K, V, TJVMK, TJVMV> using ByteBuffer for key

KNetProducerValueBuffered<K, V>

Extends KafkaProducer adding less intrusive methods which performs better in high throughput applications, extends KNetProducer<K, V, TJVMK, TJVMV> using ByteBuffer for value

KNetProducer<K, V>

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

KNetProducer<K, V, TJVMK, TJVMV>

Extends KafkaProducer adding less intrusive methods which performs better in high throughput applications

ProducerConfigBuilder

Builder for ProducerConfig

ProducerRecordBuffered<K, V>

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

ProducerRecord<K, V>

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

ProducerRecord<K, V, TJVMK, TJVMV>

KNet extension of ProducerRecord<K, V>

Interfaces

IProducer<K, V, TJVMK, TJVMV>

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

Enums

ProducerConfigBuilder.AcksTypes

Used from Acks and WithAcks(AcksTypes)

ProducerConfigBuilder.CompressionTypes

Used from CompressionType and WithCompressionType(CompressionTypes)