Class KNetConnectSink

Namespace

MASES.KNetTemplate.KNetConnect

Assembly

knetConnectSink.dll

public class KNetConnectSink : KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>, IKNetConnector, IConnector, IVersion, IKNetConnectLogging

Inheritance

object

KNetConnector

KNetConnector<KNetConnectSink>

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>

KNetConnectSink

Implements

IKNetConnector

IConnector

IVersion

IKNetConnectLogging

Inherited Members

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.Context

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.ReflectedConnectorClassName

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.TaskClassType

KNetConnector<KNetConnectSink>.ConnectorName

KNetConnector.taskDictionary

KNetConnector.ExecuteOnConnector(string, params object[])

KNetConnector.ExecuteOnConnector<T>(string, params object[])

KNetConnector.DataToExchange<T>()

KNetConnector.DataToExchange(object)

KNetConnector.Context<T>()

KNetConnector.Properties

KNetConnector.AllocateTask(long)

KNetConnector.ReflectedConnectorClassName

KNetConnector.TaskClassType

KNetConnector.Initialize(ConnectorContext)

KNetConnector.Initialize(ConnectorContext, List<Map<String, String>>)

KNetConnector.StartInternal()

KNetConnector.Start(Map<String, String>)

KNetConnector.Reconfigure(Map<String, String>)

KNetConnector.TaskClass()

KNetConnector.TaskConfigsInternal(int)

KNetConnector.TaskConfigs(int)

KNetConnector.StopInternal()

KNetConnector.Validate(Map<String, String>)

KNetConnector.Config()

KNetConnector.Version()

KNetConnector.IsTraceEnabled

KNetConnector.IsDebugEnabled

KNetConnector.IsInfoEnabled

KNetConnector.IsWarnEnabled

KNetConnector.IsErrorEnabled

KNetConnector.LogTrace(string)

KNetConnector.LogTrace(string, JVMBridgeException)

KNetConnector.LogDebug(string)

KNetConnector.LogDebug(string, JVMBridgeException)

KNetConnector.LogInfo(string)

KNetConnector.LogInfo(string, JVMBridgeException)

KNetConnector.LogWarn(string)

KNetConnector.LogWarn(string, JVMBridgeException)

KNetConnector.LogError(string)

KNetConnector.LogError(string, JVMBridgeException)

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

Start(IReadOnlyDictionary<string, string>)

Implement the method to execute the start action

public override void Start(IReadOnlyDictionary<string, string> props)

Parameters

props IReadOnlyDictionary<string, string>

The set of properties returned from Apache Kafka Connect framework: the IReadOnlyDictionary<TKey, TValue> contains the same info from configuration file.

Stop()

Implement the method to execute the stop action

public override void Stop()

TaskConfigs(int, IDictionary<string, string>)

Invoked during allocation of tasks from Apache Kafka Connect

public override void TaskConfigs(int index, IDictionary<string, string> config)

Parameters

index int

The actual index

config IDictionary<string, string>

The IDictionary<TKey, TValue> to be filled in with properties for the task: the same will be received from Start(IReadOnlyDictionary<string, string>)