public class PubSubLiteSinkConnector extends SinkConnector
Inheritance
java.lang.Object > org.apache.kafka.connect.connector.Connector > org.apache.kafka.connect.sink.SinkConnector > PubSubLiteSinkConnectorInherited Members
org.apache.kafka.connect.connector.Connector.config()
org.apache.kafka.connect.connector.Connector.initialize(org.apache.kafka.connect.connector.ConnectorContext)
org.apache.kafka.connect.connector.Connector.initialize(org.apache.kafka.connect.connector.ConnectorContext,java.util.List<java.util.Map<java.lang.String,java.lang.String>>)
org.apache.kafka.connect.connector.Connector.reconfigure(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.connector.Connector.stop()
org.apache.kafka.connect.connector.Connector.taskClass()
org.apache.kafka.connect.connector.Connector.taskConfigs(int)
org.apache.kafka.connect.connector.Connector.validate(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.sink.SinkConnector.context()
Constructors
PubSubLiteSinkConnector()
public PubSubLiteSinkConnector()
Methods
config()
public ConfigDef config()
Returns | |
---|---|
Type | Description |
org.apache.kafka.common.config.ConfigDef |
org.apache.kafka.connect.connector.Connector.config()
start(Map<String,String> map)
public void start(Map<String,String> map)
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)
stop()
public void stop()
org.apache.kafka.connect.connector.Connector.stop()
taskClass()
public Class<? extends Task> taskClass()
Returns | |
---|---|
Type | Description |
Class<? extends org.apache.kafka.connect.connector.Task> |
org.apache.kafka.connect.connector.Connector.taskClass()
taskConfigs(int i)
public List<Map<String,String>> taskConfigs(int i)
Parameter | |
---|---|
Name | Description |
i | int |
org.apache.kafka.connect.connector.Connector.taskConfigs(int)
version()
public String version()
Returns | |
---|---|
Type | Description |
String |