org.apache.kafka.connect.sink

Class SinkConnector

java.lang.Object

org.apache.kafka.connect.connector.Connector

org.apache.kafka.connect.sink.SinkConnector

@InterfaceStability.Unstable
public abstract class SinkConnector
extends Connector

SinkConnectors implement the Connector interface to send Kafka data to another system.

Field Summary

Fields

Modifier and Type	Field and Description
static String	TOPICS_CONFIG Configuration key for the list of input topics for this connector.

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

context

Constructor Summary

Constructors

Constructor and Description
SinkConnector()

Method Summary

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

config, initialize, initialize, reconfigure, start, stop, taskClass, taskConfigs, validate, version

Methods inherited from class java.lang.Object

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

Field Detail

TOPICS_CONFIG

public static final String TOPICS_CONFIG

Configuration key for the list of input topics for this connector.

Usually this setting is only relevant to the Kafka Connect framework, but is provided here for the convenience of Connector developers if they also need to know the set of topics.

See Also:

Constant Field Values

Constructor Detail

SinkConnector

public SinkConnector()