public class MockConnector
extends org.apache.kafka.connect.connector.Connector
At the moment, this connector only supports a single task and shares configuration between the connector and its tasks.
MockSinkConnector
,
MockSourceConnector
Modifier and Type | Field and Description |
---|---|
static String |
CONNECTOR_FAILURE |
static long |
DEFAULT_FAILURE_DELAY_MS |
static String |
DELAY_MS_KEY |
static String |
MOCK_MODE_KEY |
static String |
TASK_FAILURE |
Constructor and Description |
---|
MockConnector() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.config.ConfigDef |
config() |
void |
start(Map<String,String> config) |
void |
stop() |
Class<? extends org.apache.kafka.connect.connector.Task> |
taskClass() |
List<Map<String,String>> |
taskConfigs(int maxTasks) |
String |
version() |
public static final String MOCK_MODE_KEY
public static final String DELAY_MS_KEY
public static final String CONNECTOR_FAILURE
public static final String TASK_FAILURE
public static final long DEFAULT_FAILURE_DELAY_MS
public String version()
public void start(Map<String,String> config)
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