Method and Description |
---|
org.apache.kafka.connect.source.SourceTask.commitRecord(SourceRecord) |
org.apache.kafka.connect.sink.SinkTask.onPartitionsAssigned(Collection<TopicPartition>)
Use
SinkTask.open(Collection) for partition initialization. |
org.apache.kafka.connect.sink.SinkTask.onPartitionsRevoked(Collection<TopicPartition>)
Use
SinkTask.close(Collection) instead for partition cleanup. |