Package org.apache.kafka.connect.source

Class SourceConnector

java.lang.Object

org.apache.kafka.connect.connector.Connector

org.apache.kafka.connect.source.SourceConnector

All Implemented Interfaces:

Versioned

public abstract class SourceConnector
extends Connector

SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.

Field Summary

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

context

Constructor Summary

Constructors

Constructor	Description
SourceConnector()

Method Summary

Modifier and Type	Method	Description
protected SourceConnectorContext	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

Constructor Details

SourceConnector

public SourceConnector()

Method Details

context

protected SourceConnectorContext 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.