Table of Contents

Namespace MASES.KNet.Consumer

Classes

ConsumerConfigBuilder

Builder for ConsumerConfig

ConsumerRecord<K, V, TJVMK, TJVMV>

KNet extension of ConsumerRecord<K, V>

ConsumerRecords<K, V, TJVMK, TJVMV>

KNet extension of ConsumerRecords<K, V>

KNetConsumerBuffered<K, V>

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

KNetConsumerKeyBuffered<K, V>

Extends KNetConsumer<K, V, TJVMK, TJVMV> using ByteBuffer for key

KNetConsumerValueBuffered<K, V>

Extends KNetConsumer<K, V, TJVMK, TJVMV> using ByteBuffer for value

KNetConsumer<K, V>

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

KNetConsumer<K, V, TJVMK, TJVMV>

KNet extension of KafkaConsumer<K, V>

Interfaces

IConsumer<K, V, TJVMK, TJVMV>

KNet extension of IConsumer<K, V>

Enums

ConsumerConfigBuilder.AutoOffsetResetTypes

Used from AutoOffsetReset and WithAutoOffsetReset(AutoOffsetResetTypes)