Class KNetClientSupplier
KNet implementation of KafkaClientSupplier
public class KNetClientSupplier : KafkaClientSupplier, IDynamicMetaObjectProvider, IJVMBridgeCore, 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()
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)