public abstract class SinkConnector extends Connector
Modifier and Type | Field and Description |
---|---|
static String |
TOPICS_CONFIG
Configuration key for the list of input topics for this connector.
|
Constructor and Description |
---|
SinkConnector() |
config, initialize, initialize, reconfigure, start, stop, taskClass, taskConfigs, validate, version
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.