org.apache.kafka.connect.tools

Class MockConnector

java.lang.Object

org.apache.kafka.connect.connector.Connector

org.apache.kafka.connect.tools.MockConnector

All Implemented Interfaces:

Versioned

public class MockConnector
extends Connector

This connector provides support for mocking certain connector behaviors. For example, this can be used to simulate connector or task failures. It works by passing a "mock mode" through configuration from the system test. New mock behavior can be implemented either in the connector or in the task by providing a new mode implementation.

At the moment, this connector only supports a single task and shares configuration between the connector and its tasks.

See Also:

MockSinkConnector, MockSourceConnector

Field Summary

Fields

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

Fields inherited from class org.apache.kafka.connect.connector.Connector

context

Constructor Summary

Constructors

Constructor and Description
MockConnector()

Method Summary

Modifier and Type	Method and Description
ConfigDef	config() Define the configuration for the connector.
void	start(Map<String,String> config) Start this Connector.
void	stop() Stop this connector.
Class<? extends Task>	taskClass() Returns the Task implementation for this Connector.
List<Map<String,String>>	taskConfigs(int maxTasks) Returns a set of configurations for Tasks based on the current configuration, producing at most maxTasks configurations.
String	version() Get the version of this component.

Methods inherited from class org.apache.kafka.connect.connector.Connector

context, initialize, initialize, reconfigure, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MOCK_MODE_KEY

public static final String MOCK_MODE_KEY

See Also:

Constant Field Values

DELAY_MS_KEY

public static final String DELAY_MS_KEY

See Also:

Constant Field Values

CONNECTOR_FAILURE

public static final String CONNECTOR_FAILURE

See Also:

Constant Field Values

TASK_FAILURE

public static final String TASK_FAILURE

See Also:

Constant Field Values

DEFAULT_FAILURE_DELAY_MS

public static final long DEFAULT_FAILURE_DELAY_MS

See Also:

Constant Field Values

Constructor Detail

MockConnector

public MockConnector()

Method Detail

version

public String version()

Description copied from interface: Versioned

Get the version of this component.

Returns:

the version, formatted as a String. The version may not be null or empty.

start

public void start(Map<String,String> config)

Description copied from class: Connector

Start this Connector. This method will only be called on a clean Connector, i.e. it has either just been instantiated and initialized or Connector.stop() has been invoked.

Specified by:

start in class Connector

Parameters:

config - configuration settings

taskClass

public Class<? extends Task> taskClass()

Description copied from class: Connector

Returns the Task implementation for this Connector.

Specified by:

taskClass in class Connector

taskConfigs

public List<Map<String,String>> taskConfigs(int maxTasks)

Description copied from class: Connector

Returns a set of configurations for Tasks based on the current configuration, producing at most maxTasks configurations.

Specified by:

taskConfigs in class Connector

Parameters:

maxTasks - maximum number of configurations to generate

Returns:

configurations for Tasks

stop

public void stop()

Description copied from class: Connector

Stop this connector.

Specified by:

stop in class Connector

config

public ConfigDef config()

Description copied from class: Connector

Define the configuration for the connector.

Specified by:

config in class Connector

Returns:

The ConfigDef for this connector; may not be null.