Class PubSubLiteSinkTask (0.1.5)

public class PubSubLiteSinkTask extends SinkTask

Inheritance

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

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

PubSubLiteSinkTask()

public PubSubLiteSinkTask()

Methods

flush(Map<TopicPartition,OffsetAndMetadata> currentOffsets)

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

Parameter

Name	Description
currentOffsets	`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> collection)

public void put(Collection<SinkRecord> collection)

Parameter

Name	Description
collection	`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> map)

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

Parameter

Name	Description
map	`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