Class KNetClientSupplier
KNet implementation of KafkaClientSupplier
public class KNetClientSupplier : KafkaClientSupplier, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IKafkaClientSupplier- Inheritance
-
JVMBridgeBaseJVMBridgeBase<JVMBridgeListener>JVMBridgeListenerKNetClientSupplier
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeListener.AutoInitJVMBridgeListener.IsBridgeStaticJVMBridgeListener.IsBridgeCloseableJVMBridgeListener.IsBridgeListenerJVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])JVMBridgeBase<JVMBridgeListener>.DynBridgeClazzJVMBridgeBase<JVMBridgeListener>.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.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeInterfaceJVMBridgeBase.IsBridgeAbstract
Remarks
The default KafkaClientSupplier used from KafkaStreams allocates both KafkaConsumer and KafkaProducer. KNetClientSupplier uses KNetConsumer<K, V, TJVMK, TJVMV> and KNetProducer<K, V, TJVMK, TJVMV>, the instance shall be disposed when no more in use, but still be alive still KafkaStreams is alive.
Constructors
KNetClientSupplier()
Default initializer
public KNetClientSupplier()Methods
Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
public override void Dispose()GetAdmin(Map<String, object>)
public override Admin GetAdmin(Map<String, object> arg0)Parameters
Returns
Remarks
The method invokes the default implementation in the JVM interface using GetAdminDefault(Map<String, object>); override the method to implement a different behavior
GetConsumer(Map<String, object>)
public override Consumer<byte[], byte[]> GetConsumer(Map<String, object> arg0)Parameters
Returns
GetGlobalConsumer(Map<String, object>)
public override Consumer<byte[], byte[]> GetGlobalConsumer(Map<String, object> arg0)Parameters
Returns
GetProducer(Map<String, object>)
public override Producer<byte[], byte[]> GetProducer(Map<String, object> arg0)Parameters
Returns
GetRestoreConsumer(Map<String, object>)
public override Consumer<byte[], byte[]> GetRestoreConsumer(Map<String, object> arg0)