public class PubSubLiteSinkConnector extends SinkConnector
Inheritance
java.lang.Object >
org.apache.kafka.connect.connector.Connector >
org.apache.kafka.connect.sink.SinkConnector >
PubSubLiteSinkConnector
Inherited 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 | |
Overrides
org.apache.kafka.connect.connector.Connector.config()
start(Map<String,String> map)
public void start(Map<String,String> map)
Overrides
org.apache.kafka.connect.connector.Connector.start(java.util.Map<java.lang.String,java.lang.String>)
stop()
Overrides
org.apache.kafka.connect.connector.Connector.stop()
taskClass()
public Class<? extends Task> taskClass()
Returns |
---|
Type | Description |
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 |
---|
Name | Description |
i | int
|
Overrides
org.apache.kafka.connect.connector.Connector.taskConfigs(int)
version()