public class PubSubLiteSinkTask extends SinkTask
Inherited Members
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> |
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> |
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)
org.apache.kafka.connect.sink.SinkTask.start(java.util.Map<java.lang.String,java.lang.String>)
stop()
public void stop()
org.apache.kafka.connect.sink.SinkTask.stop()
version()
public String version()
Returns | |
---|---|
Type | Description |
String |