Interface IKNetTask

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

Specific implementation of ITask to support KNet Connect SDK

public interface IKNetTask : ITask, IKNetCommon, IKNetConnectLogging

Inherited Members

ITask.Version()

ITask.Start(Map<String, String>)

ITask.Stop()

IKNetCommon.Properties

IKNetCommon.ExecuteOnRemote(string, params object[])

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

IKNetConnectLogging.Name

IKNetConnectLogging.IsTraceEnabled

IKNetConnectLogging.LogTrace(string)

IKNetConnectLogging.LogTrace(string, JVMBridgeException)

IKNetConnectLogging.LogTrace(string, params object[])

IKNetConnectLogging.IsDebugEnabled

IKNetConnectLogging.LogDebug(string)

IKNetConnectLogging.LogDebug(string, JVMBridgeException)

IKNetConnectLogging.LogDebug(string, params object[])

IKNetConnectLogging.IsInfoEnabled

IKNetConnectLogging.LogInfo(string)

IKNetConnectLogging.LogInfo(string, JVMBridgeException)

IKNetConnectLogging.LogInfo(string, params object[])

IKNetConnectLogging.IsWarnEnabled

IKNetConnectLogging.LogWarn(string)

IKNetConnectLogging.LogWarn(string, JVMBridgeException)

IKNetConnectLogging.LogWarn(string, params object[])

IKNetConnectLogging.IsErrorEnabled

IKNetConnectLogging.LogError(string)

IKNetConnectLogging.LogError(string, JVMBridgeException)

IKNetConnectLogging.LogError(string, params object[])

Properties

Connector

The associated IConnector

IKNetConnector Connector { get; }

Property Value

IKNetConnector

TaskId

The id received during initialization

long TaskId { get; }

Property Value

long

Methods

Start(IKNetConnectConfiguration)

Implement the method to execute the start action

void Start(IKNetConnectConfiguration props)

Parameters

props IKNetConnectConfiguration

The IKNetConnectConfiguration to access the properties returned from Apache Kafka Connect framework: the Properties contains the info from TaskConfigs(int, int, IKNetTaskConfiguration).