Class PubSubLiteSourceConnector (1.2.0)

public class PubSubLiteSourceConnector extends SourceConnector

Inheritance

java.lang.Object > org.apache.kafka.connect.connector.Connector > org.apache.kafka.connect.source.SourceConnector > PubSubLiteSourceConnector

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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.source.SourceConnector.canDefineTransactionBoundaries(java.util.Map<java.lang.String,java.lang.String>)

org.apache.kafka.connect.source.SourceConnector.context()

org.apache.kafka.connect.source.SourceConnector.exactlyOnceSupport(java.util.Map<java.lang.String,java.lang.String>)

Constructors

PubSubLiteSourceConnector()

public PubSubLiteSourceConnector()

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)

Parameter
Name	Description
`map`	`Map<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
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`

Returns
Type	Description
`List<Map<String,String>>`

Overrides

org.apache.kafka.connect.connector.Connector.taskConfigs(int)

version()

public String version()

Returns
Type	Description
`String`