Table of Contents

Class KNetConsumerBuffered<K, V>

Namespace
MASES.KNet.Consumer
Assembly
MASES.KNet.dll

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

public class KNetConsumerBuffered<K, V> : KNetConsumer<K, V, ByteBuffer, ByteBuffer>, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IConsumer<K, V, ByteBuffer, ByteBuffer>, IConsumer<ByteBuffer, ByteBuffer>, IConsumer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

The key type

V

The value type

Inheritance
KNetConsumerBuffered<K, V>
Implements
Inherited Members
Extension Methods

Constructors

KNetConsumerBuffered(ConsumerConfigBuilder, ISerDes<K, ByteBuffer>, ISerDes<V, ByteBuffer>, bool)

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

public KNetConsumerBuffered(ConsumerConfigBuilder props, ISerDes<K, ByteBuffer> keyDeserializer, ISerDes<V, ByteBuffer> valueDeserializer, bool useJVMCallback = false)

Parameters

props ConsumerConfigBuilder

The properties to use, see ConsumerConfigBuilder

keyDeserializer ISerDes<K, ByteBuffer>

Key serializer base on SerDes<T, TJVMT>

valueDeserializer ISerDes<V, ByteBuffer>

Value serializer base on SerDes<T, TJVMT>

useJVMCallback bool

true to active callback based mode

KNetConsumerBuffered(ConsumerConfigBuilder, bool)

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

public KNetConsumerBuffered(ConsumerConfigBuilder configBuilder, bool useJVMCallback = false)

Parameters

configBuilder ConsumerConfigBuilder

An instance of ConsumerConfigBuilder

useJVMCallback bool

true to active callback based mode

Edit this page