Page History

package org.apache.kafka.connect.source;

// imports

public abstract class SourceTask implements Task {

    protected SourceTaskContext context;

// ...
    /**
     * ....
     * @deprecated Use {@link #commitRecord(SourceRecord, RecordMetadata)} instead.
     */
    @Deprecated
    public void commitRecord(SourceRecord record) throws InterruptedException {
    }

// ...