@Override
    protected void recordSent(
            SourceRecord sourceRecord,
            ProducerRecord<byte[], byte[]> producerRecord,
            RecordMetadata recordMetadata
    ) {
        commitTaskRecord(sourceRecord, recordMetadata);
    }
{@link WorkerTask} that uses a {@link SourceTask} to ingest data into Kafka.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java