Some or all of the information on this page might not apply to Trusted Cloud by S3NS. See Differences from Google Cloud for more details.

Class PubSubLiteSourceTask (1.0.0)

public class PubSubLiteSourceTask extends SourceTask

Inheritance

java.lang.Object > org.apache.kafka.connect.source.SourceTask > PubSubLiteSourceTask

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.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
Type	Description
`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
Name	Description
`props`	`Map<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
Type	Description
`String`