Class KNetConnectSource

Namespace

MASES.KNetTemplate.KNetConnect

Assembly

knetConnectSource.dll

public class KNetConnectSource : KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>, IKNetConnector, IConnector, IVersion, IKNetConnectLogging

Inheritance

object

KNetConnector

KNetConnector<KNetConnectSource>

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>

KNetConnectSource

Implements

IKNetConnector

IConnector

IVersion

IKNetConnectLogging

Inherited Members

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.Context

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.ExactlyOnceSupportInternal()

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.ExactlyOnceSupport

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.CanDefineTransactionBoundariesInternal()

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.CanDefineTransactionBoundaries()

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.ReflectedConnectorClassName

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.TaskClassType

KNetConnector<KNetConnectSource>.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>)