public class MockSinkConnector
extends org.apache.kafka.connect.sink.SinkConnector
MockConnector
.Constructor and Description |
---|
MockSinkConnector() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.config.ConfigDef |
config() |
void |
initialize(org.apache.kafka.connect.connector.ConnectorContext ctx) |
void |
initialize(org.apache.kafka.connect.connector.ConnectorContext ctx,
List<Map<String,String>> taskConfigs) |
void |
reconfigure(Map<String,String> props) |
void |
start(Map<String,String> props) |
void |
stop() |
Class<? extends org.apache.kafka.connect.connector.Task> |
taskClass() |
List<Map<String,String>> |
taskConfigs(int maxTasks) |
org.apache.kafka.common.config.Config |
validate(Map<String,String> connectorConfigs) |
String |
version() |
public void initialize(org.apache.kafka.connect.connector.ConnectorContext ctx)
initialize
in class org.apache.kafka.connect.connector.Connector
public void initialize(org.apache.kafka.connect.connector.ConnectorContext ctx, List<Map<String,String>> taskConfigs)
initialize
in class org.apache.kafka.connect.connector.Connector
public void reconfigure(Map<String,String> props)
reconfigure
in class org.apache.kafka.connect.connector.Connector
public org.apache.kafka.common.config.Config validate(Map<String,String> connectorConfigs)
validate
in class org.apache.kafka.connect.connector.Connector
public String version()
public void start(Map<String,String> props)
start
in class org.apache.kafka.connect.connector.Connector
public Class<? extends org.apache.kafka.connect.connector.Task> taskClass()
taskClass
in class org.apache.kafka.connect.connector.Connector
public List<Map<String,String>> taskConfigs(int maxTasks)
taskConfigs
in class org.apache.kafka.connect.connector.Connector
public void stop()
stop
in class org.apache.kafka.connect.connector.Connector
public org.apache.kafka.common.config.ConfigDef config()
config
in class org.apache.kafka.connect.connector.Connector