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
- 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)