Class 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
public class KNetProducerValueBuffered<K, V> : KNetProducer<K, V, byte[], ByteBuffer>, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IProducer<K, V, byte[], ByteBuffer>, IProducer<byte[], ByteBuffer>, IProducer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable
Type Parameters
K
Same meaning of KafkaProducer
V
Same meaning of KafkaProducer
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>KNetProducerValueBuffered<K, V>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])JVMBridgeBase<AutoCloseable>.DynBridgeClazzJVMBridgeBase<AutoCloseable>.BridgeClazzJVMBridgeBase.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.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
- Extension Methods
Constructors
KNetProducerValueBuffered(ProducerConfigBuilder)
Initialize a new instance of KNetProducer<K, V, TJVMK, TJVMV>
public KNetProducerValueBuffered(ProducerConfigBuilder configBuilder)
Parameters
configBuilder
ProducerConfigBuilderAn instance of ProducerConfigBuilder
KNetProducerValueBuffered(ProducerConfigBuilder, ISerDes<K, byte[]>, ISerDes<V, ByteBuffer>)
Initialize a new instance of KNetProducer<K, V, TJVMK, TJVMV>
public KNetProducerValueBuffered(ProducerConfigBuilder props, ISerDes<K, byte[]> keySerializer, ISerDes<V, ByteBuffer> valueSerializer)
Parameters
props
ProducerConfigBuilderThe properties to use, see ProducerConfigBuilder
keySerializer
ISerDes<K, byte[]>Key serializer base on SerDes<T, TJVMT>
valueSerializer
ISerDes<V, ByteBuffer>Value serializer base on SerDes<T, TJVMT>