Class CloudPubSubSinkTask (1.1.0)

Version 1.1.0

• 1.2.0 (latest)
• 1.1.0
• 1.0.0
• 0.1.5

public class CloudPubSubSinkTask extends SinkTask

A SinkTask used by a CloudPubSubSinkConnector to write messages to Google Cloud Pub/Sub.

Inheritance

java.lang.Object > org.apache.kafka.connect.sink.SinkTask > CloudPubSubSinkTask

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.sink.SinkTask.close(java.util.Collection<org.apache.kafka.common.TopicPartition>)

org.apache.kafka.connect.sink.SinkTask.flush(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>)

org.apache.kafka.connect.sink.SinkTask.initialize(org.apache.kafka.connect.sink.SinkTaskContext)

org.apache.kafka.connect.sink.SinkTask.onPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition>)

org.apache.kafka.connect.sink.SinkTask.onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition>)

org.apache.kafka.connect.sink.SinkTask.open(java.util.Collection<org.apache.kafka.common.TopicPartition>)

org.apache.kafka.connect.sink.SinkTask.preCommit(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>)

org.apache.kafka.connect.sink.SinkTask.put(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord>)

org.apache.kafka.connect.sink.SinkTask.start(java.util.Map<java.lang.String,java.lang.String>)

org.apache.kafka.connect.sink.SinkTask.stop()

Constructors

CloudPubSubSinkTask()

public CloudPubSubSinkTask()

CloudPubSubSinkTask(Publisher publisher)

public CloudPubSubSinkTask(Publisher publisher)

Parameter
Name	Description
publisher	com.google.cloud.pubsub.v1.Publisher

Methods

flush(Map<TopicPartition,OffsetAndMetadata> partitionOffsets)

public void flush(Map<TopicPartition,OffsetAndMetadata> partitionOffsets)

Parameter
Name	Description
partitionOffsets	Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>

Overrides

org.apache.kafka.connect.sink.SinkTask.flush(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>)

put(Collection<SinkRecord> sinkRecords)

public void put(Collection<SinkRecord> sinkRecords)

Parameter
Name	Description
sinkRecords	Collection<org.apache.kafka.connect.sink.SinkRecord>

Overrides

org.apache.kafka.connect.sink.SinkTask.put(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord>)

start(Map<String,String> props)

public void start(Map<String,String> props)

Parameter
Name	Description
props	Map<String,String>

Overrides

org.apache.kafka.connect.sink.SinkTask.start(java.util.Map<java.lang.String,java.lang.String>)

stop()

public void stop()

Overrides

org.apache.kafka.connect.sink.SinkTask.stop()

version()

public String version()

Returns
Type	Description
String