public class CloudPubSubSourceTask extends SourceTask
A SourceTask used by a CloudPubSubSourceConnector to write messages to Apache Kafka. Due to at-last-once semantics in Google Cloud Pub/Sub duplicates in Kafka are possible.
Inherited Members
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
CloudPubSubSourceTask()
public CloudPubSubSourceTask()
CloudPubSubSourceTask(CloudPubSubSubscriber subscriber)
public CloudPubSubSourceTask(CloudPubSubSubscriber subscriber)
Parameter | |
---|---|
Name | Description |
subscriber | CloudPubSubSubscriber |
Methods
commitRecord(SourceRecord record)
public void commitRecord(SourceRecord record)
Parameter | |
---|---|
Name | Description |
record | org.apache.kafka.connect.source.SourceRecord |
org.apache.kafka.connect.source.SourceTask.commitRecord(org.apache.kafka.connect.source.SourceRecord)
poll()
public List<SourceRecord> poll()
Returns | |
---|---|
Type | Description |
List<org.apache.kafka.connect.source.SourceRecord> |
org.apache.kafka.connect.source.SourceTask.poll()
Exceptions | |
---|---|
Type | Description |
InterruptedException |
start(Map<String,String> props)
public void start(Map<String,String> props)
org.apache.kafka.connect.source.SourceTask.start(java.util.Map<java.lang.String,java.lang.String>)
stop()
public void stop()
org.apache.kafka.connect.source.SourceTask.stop()
version()
public String version()
Returns | |
---|---|
Type | Description |
String |