Interface IKNetConnector

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

Specific implementation of IConnector to support KNet Connect SDK

public interface IKNetConnector : IConnector, IVersion

Inherited Members

IConnector.Initialize(ConnectorContext)

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

IConnector.Start(Map<String, String>)

IConnector.Reconfigure(Map<String, String>)

IConnector.TaskClass()

IConnector.TaskConfigs(int)

IConnector.Stop()

IConnector.Validate(Map<String, String>)

IConnector.Config()

IVersion.Version()

Properties

ConnectorName

The unique name of the connector

string ConnectorName { get; }

Property Value

string

Properties

The properties retrieved from StartInternal()

IReadOnlyDictionary<string, string> Properties { get; }

Property Value

IReadOnlyDictionary<string, string>

TaskClassType

The Type of task to be allocated, it shall inherits from KNetTask

Type TaskClassType { get; }

Property Value

Type

Methods

AllocateTask(long)

Allocates a task object based on KNetTask

object AllocateTask(long taskId)

Parameters

taskId long

The unique id generated from JAva side

Returns

object

The local .NET object

Start(IReadOnlyDictionary<string, string>)

Implement the method to execute the start action

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.

TaskConfigs(int, IDictionary<string, string>)

Invoked during allocation of tasks from Apache Kafka Connect

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