Package org.apache.kafka.connect.sink

Class SinkConnector

java.lang.Object

org.apache.kafka.connect.connector.Connector

org.apache.kafka.connect.sink.SinkConnector

All Implemented Interfaces:

Versioned

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	Description
static final 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	Description
SinkConnector()

Method Summary

Modifier and Type	Method	Description
protected SinkConnectorContext	context()	Returns the context object used to interact with the Kafka Connect runtime.

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.connect.components.Versioned

version

Field Details

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 Details

SinkConnector

public SinkConnector()

Method Details

context

protected SinkConnectorContext context()

Description copied from class: Connector

Returns the context object used to interact with the Kafka Connect runtime.

Overrides:

context in class Connector

Returns:

the context for this Connector.