Class KNetClientSupplier
KNet implementation of KafkaClientSupplier
public class KNetClientSupplier : KafkaClientSupplier, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IKafkaClientSupplier- Inheritance
-
KNetClientSupplier
- Implements
- Inherited Members
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(bool)
Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose
protected override void Dispose(bool disposing)Parameters
disposingboolThe disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)
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)