Class PubSubLiteSinkTask (1.2.0) 

public class PubSubLiteSinkTask extends SinkTask

Inheritance

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

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