protected void commitTaskRecord(SourceRecord record, RecordMetadata metadata) {
        try {
            task.commitRecord(record, metadata);
        } catch (Throwable t) {
            log.error("{} Exception thrown while calling task.commitRecord()", this, t);
        }
    }
Convert the source record into a producer record.

@param record the transformed record
@return the producer record which can sent over to Kafka. A null is returned if the input is null or
if an error was encountered during any of the converter stages.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java