Class KNetConnectSink

Namespace

MASES.KNet.Template.KNetConnect

Assembly

knetConnectSink.dll

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

Inheritance

object

KNetCommon

KNetConnector

KNetConnector<KNetConnectSink>

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>

KNetConnectSink

Implements

IKNetSinkConnector

IKNetConnector

IKNetCommon

IKNetConnectLogging

IConnector

IVersion

Inherited Members

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.Context

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.ReflectedRemoteObjectClassName

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.TaskClassType

KNetSinkConnector<KNetConnectSink, KNetConnectSinkTask>.AlterOffsets(Map<String, String>, Map<TopicPartition, Long>)

KNetConnector<KNetConnectSink>.ConnectorName

KNetConnector.taskDictionary

KNetConnector.Context<T>()

KNetConnector.TaskClassType

KNetConnector.Start(Map<String, object>)

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

KNetCommon.LogCheckInterval

KNetCommon.UniqueId

KNetCommon.Properties

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

Implement the method to execute the start action

public override void Start(IKNetConfigurationFromMap props)

Parameters

props IKNetConfigurationFromMap

Stop()

Implement the method to execute the stop action

public override void Stop()

TaskConfigs(int, int, IKNetTaskConfiguration)

Invoked during allocation of tasks from Apache Kafka Connect

public override bool TaskConfigs(int index, int maxTasks, IKNetTaskConfiguration config)

Parameters

index int

maxTasks int

Max tasks as defined from Apache Kafka Connect framework

config IKNetTaskConfiguration

The IKNetTaskConfiguration to be filled in with properties for the task: the same will be received from Start(IKNetConfigurationFromMap)

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.