Interface IConnector

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

.NET interface for Connector

public interface IConnector : IVersion

Inherited Members

IVersion.Version()

Methods

Config()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#config--

ConfigDef Config()

Returns

ConfigDef

ConfigDef

Initialize(ConnectorContext)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#initialize-org.apache.kafka.connect.connector.ConnectorContext-

void Initialize(ConnectorContext ctx)

Parameters

ctx ConnectorContext

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

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#initialize-org.apache.kafka.connect.connector.ConnectorContext-java.util.List-

void Initialize(ConnectorContext ctx, List<Map<String, String>> taskConfigs)

Parameters

ctx ConnectorContext

taskConfigs List<Map<String, String>>

Reconfigure(Map<String, String>)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#reconfigure-java.util.Map-

void Reconfigure(Map<String, String> props)

Parameters

props Map<String, String>

Start(Map<String, String>)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#start-java.util.Map-

void Start(Map<String, String> props)

Parameters

props Map<String, String>

Stop()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#stop--

void Stop()

TaskClass()

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#taskClass--

Class TaskClass()

Returns

Class

Class

TaskConfigs(int)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#taskConfigs-int-

List<Map<String, String>> TaskConfigs(int maxTasks)

Parameters

maxTasks int

Returns

List<Map<String, String>>

List

Validate(Map<String, String>)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/connector/Connector.html#validate-java.util.Map-

Config Validate(Map<String, String> connectorConfigs)

Parameters

connectorConfigs Map<String, String>

Returns

Config

Config