Class KNetConnectSource

Namespace

MASES.KNet.Template.KNetConnect

Assembly

knetConnectSource.dll

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

Inheritance

object

KNetCommon

KNetConnector

KNetConnector<KNetConnectSource>

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>

KNetConnectSource

Implements

IKNetSourceConnector

IKNetConnector

IKNetCommon

IKNetConnectLogging

IConnector

IVersion

Inherited Members

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.Context

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.ExactlyOnceSupport

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.CanDefineTransactionBoundaries

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.ReflectedRemoteObjectClassName

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.TaskClassType

KNetSourceConnector<KNetConnectSource, KNetConnectSourceTask>.AlterOffsets(Map<String, String>, Map<Map<String, object>, Map<String, object>>)

KNetConnector<KNetConnectSource>.ConnectorName

KNetConnector.taskDictionary

KNetConnector.Context<T>()

KNetConnector.Properties

KNetConnector.AllocateTask(long)

KNetConnector.TaskClassType

KNetConnector.Initialize(ConnectorContext)

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

KNetConnector.Start(Map<String, String>)

KNetConnector.Reconfigure(Map<String, String>)

KNetConnector.TaskClass()

KNetConnector.TaskConfigs(int, int, Map<String, String>)

KNetConnector.TaskConfigs(int)

KNetConnector.Validate(Map<String, String>)

KNetConnector.Config()

KNetConnector.Version()

KNetCommon.UniqueId

KNetCommon.ExecuteOnRemote(string, params object[])

KNetCommon.ExecuteOnRemote<T>(string, params object[])

KNetCommon.DataToExchange<T>()

KNetCommon.DataToExchange(object)

KNetCommon.ReflectedRemoteObjectClassName

KNetCommon.Name

KNetCommon.IsTraceEnabled

KNetCommon.LogTrace(string)

KNetCommon.LogTrace(string, JVMBridgeException)

KNetCommon.LogTrace(string, params object[])

KNetCommon.IsDebugEnabled

KNetCommon.LogDebug(string)

KNetCommon.LogDebug(string, JVMBridgeException)

KNetCommon.LogDebug(string, params object[])

KNetCommon.IsInfoEnabled

KNetCommon.LogInfo(string)

KNetCommon.LogInfo(string, JVMBridgeException)

KNetCommon.LogInfo(string, params object[])

KNetCommon.IsWarnEnabled

KNetCommon.LogWarn(string)

KNetCommon.LogWarn(string, JVMBridgeException)

KNetCommon.LogWarn(string, params object[])

KNetCommon.IsErrorEnabled

KNetCommon.LogError(string)

KNetCommon.LogError(string, JVMBridgeException)

KNetCommon.LogError(string, params object[])

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, int, IDictionary<string, string>)

Invoked during allocation of tasks from Apache Kafka Connect

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

Parameters

index int

maxTasks int

Max tasks as defined from Apache Kafka Connect framework

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>)

Returns

bool

true to avoid any further invocation of the method, otherwise false.

Remarks

If the connector needs a single task and maxTasks is higher than 1, returning true immediately only one configuration is returned to Apache Kafka Connect framework. In other word it is possible to stop the configuration requests at any time; only the first one is reported in any case since at least one shall be available. To configure all maxTasks return always false.