Interface IKNetTask

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

Specific implementation of ITask to support KNet Connect SDK

public interface IKNetTask : ITask

Inherited Members

ITask.Version()

ITask.Start(Map<String, String>)

ITask.Stop()

Properties

Connector

The associated IConnector

IKNetConnector Connector { get; }

Property Value

IKNetConnector

Properties

The properties retrieved from StartInternal()

IReadOnlyDictionary<string, string> Properties { get; }

Property Value

IReadOnlyDictionary<string, string>

TaskId

The id received during initialization

long TaskId { get; }

Property Value

long

Methods

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 info from TaskConfigs(int, IDictionary<string, string>).