void recordWrite(int recordCount, int skippedCount) {
            sourceRecordWrite.record(recordCount - skippedCount);
            activeRecordCount -= recordCount;
            activeRecordCount = Math.max(0, activeRecordCount);
            sourceRecordActiveCount.record(activeRecordCount);
        }
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