Class CloudPubSubSinkTask (1.2.0)

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`