Class 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
public class KNetProducer<K, V> : KNetProducer<K, V, byte[], byte[]>, IDynamicMetaObjectProvider, IJVMBridgeCore, IJVMBridgeBaseStatic, IProducer<K, V, byte[], byte[]>, IProducer<byte[], byte[]>, IProducer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable
Type Parameters
K
Same meaning of KafkaProducer
V
Same meaning of KafkaProducer
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>KNetProducer<K, V>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
KNetProducer<K, V, byte[], byte[]>.Produce(string, K, V, Action<RecordMetadata, JVMBridgeException>)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
KNetProducer(ProducerConfigBuilder)
Initialize a new instance of KNetProducer<K, V, TJVMK, TJVMV>
public KNetProducer(ProducerConfigBuilder configBuilder)
Parameters
configBuilder
ProducerConfigBuilderAn instance of ProducerConfigBuilder
KNetProducer(ProducerConfigBuilder, ISerDes<K, byte[]>, ISerDes<V, byte[]>)
Initialize a new instance of KNetProducer<K, V, TJVMK, TJVMV>
public KNetProducer(ProducerConfigBuilder props, ISerDes<K, byte[]> keySerializer, ISerDes<V, byte[]> valueSerializer)
Parameters
props
ProducerConfigBuilderThe properties to use, see ProducerConfigBuilder
keySerializer
ISerDes<K, byte[]>Key serializer base on SerDes<T, TJVMT>
valueSerializer
ISerDes<V, byte[]>Value serializer base on SerDes<T, TJVMT>