Package org.apache.kafka.connect.tools

Class VerifiableSinkConnector

java.lang.Object

org.apache.kafka.connect.connector.Connector

org.apache.kafka.connect.sink.SinkConnector

org.apache.kafka.connect.tools.VerifiableSinkConnector

All Implemented Interfaces:

Versioned

public class VerifiableSinkConnector
extends SinkConnector

A connector primarily intended for system tests.

See Also:

• VerifiableSinkTask

Field Summary

Fields inherited from class org.apache.kafka.connect.sink.SinkConnector

TOPICS_CONFIG

Constructor Summary

Constructors

Constructor	Description
VerifiableSinkConnector()

Method Summary

Modifier and Type	Method	Description
ConfigDef	config()	Define the configuration for the connector.
void	start(Map<String,String> props)	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.sink.SinkConnector

alterOffsets

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

initialize, initialize, reconfigure, validate

Methods inherited from class java.lang.Object

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

Constructor Details

VerifiableSinkConnector

public VerifiableSinkConnector()

Method Details

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> props)

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:

props - 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.