Class PubSubLiteSourceTask (1.1.0)

public class PubSubLiteSourceTask extends SourceTask

Inheritance

java.lang.Object > org.apache.kafka.connect.source.SourceTask > PubSubLiteSourceTask
org.apache.kafka.connect.source.SourceTask.commit()
org.apache.kafka.connect.source.SourceTask.commitRecord(org.apache.kafka.connect.source.SourceRecord)
org.apache.kafka.connect.source.SourceTask.commitRecord(org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.clients.producer.RecordMetadata)
org.apache.kafka.connect.source.SourceTask.initialize(org.apache.kafka.connect.source.SourceTaskContext)
org.apache.kafka.connect.source.SourceTask.poll()
org.apache.kafka.connect.source.SourceTask.start(java.util.Map<java.lang.String,java.lang.String>)
org.apache.kafka.connect.source.SourceTask.stop()

Constructors

PubSubLiteSourceTask()

public PubSubLiteSourceTask()

Methods

poll()

public List<SourceRecord> poll()
Returns
TypeDescription
List<org.apache.kafka.connect.source.SourceRecord>
Overrides
org.apache.kafka.connect.source.SourceTask.poll()

start(Map<String,String> props)

public void start(Map<String,String> props)
Parameter
NameDescription
propsMap<String,String>
Overrides
org.apache.kafka.connect.source.SourceTask.start(java.util.Map<java.lang.String,java.lang.String>)

stop()

public void stop()
Overrides
org.apache.kafka.connect.source.SourceTask.stop()

version()

public String version()
Returns
TypeDescription
String