Class PubSubLiteSinkConnector (1.1.0)

public class PubSubLiteSinkConnector extends SinkConnector

Inheritance

java.lang.Object > org.apache.kafka.connect.connector.Connector > org.apache.kafka.connect.sink.SinkConnector > PubSubLiteSinkConnector

Constructors

PubSubLiteSinkConnector()

public PubSubLiteSinkConnector()

Methods

config()

public ConfigDef config()
Returns
TypeDescription
org.apache.kafka.common.config.ConfigDef
Overrides
org.apache.kafka.connect.connector.Connector.config()

start(Map<String,String> map)

public void start(Map<String,String> map)
Parameter
NameDescription
mapMap<String,String>
Overrides
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)

stop()

public void stop()
Overrides
org.apache.kafka.connect.connector.Connector.stop()

taskClass()

public Class<? extends Task> taskClass()
Returns
TypeDescription
Class<? extends org.apache.kafka.connect.connector.Task>
Overrides
org.apache.kafka.connect.connector.Connector.taskClass()

taskConfigs(int i)

public List<Map<String,String>> taskConfigs(int i)
Parameter
NameDescription
iint
Returns
TypeDescription
List<Map<String,String>>
Overrides
org.apache.kafka.connect.connector.Connector.taskConfigs(int)

version()

public String version()
Returns
TypeDescription
String