Deprecated API

Contents

• Deprecated Methods

Deprecated Methods

Method and Description
org.apache.kafka.connect.source.SourceTask.commitRecord(SourceRecord) Use SourceTask.commitRecord(SourceRecord, RecordMetadata) instead.
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.