Table of Contents

Class KNetConsumer<K, V>

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

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

public class KNetConsumer<K, V> : KNetConsumer<K, V, byte[], byte[]>, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IConsumer<K, V, byte[], byte[]>, IConsumer<byte[], byte[]>, IConsumer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

The key type

V

The value type

Inheritance
JVMBridgeBase
JVMBridgeBase<AutoCloseable>
KNetConsumer<K, V, byte[], byte[]>
KNetConsumer<K, V>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IConsumer<K, V, byte[], byte[]>
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)
JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()
JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])
JVMBridgeBase<AutoCloseable>.DynBridgeClazz
JVMBridgeBase<AutoCloseable>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener
Extension Methods

Constructors

KNetConsumer(ConsumerConfigBuilder, ISerDes<K, byte[]>, ISerDes<V, byte[]>, bool)

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

public KNetConsumer(ConsumerConfigBuilder props, ISerDes<K, byte[]> keyDeserializer, ISerDes<V, byte[]> valueDeserializer, bool useJVMCallback = false)

Parameters

props ConsumerConfigBuilder

The properties to use, see ConsumerConfigBuilder

keyDeserializer ISerDes<K, byte[]>

Key serializer base on SerDes<T, TJVMT>

valueDeserializer ISerDes<V, byte[]>

Value serializer base on SerDes<T, TJVMT>

useJVMCallback bool

true to active callback based mode

KNetConsumer(ConsumerConfigBuilder, bool)

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

public KNetConsumer(ConsumerConfigBuilder configBuilder, bool useJVMCallback = false)

Parameters

configBuilder ConsumerConfigBuilder

An instance of ConsumerConfigBuilder

useJVMCallback bool

true to active callback based mode