@Override
    public SinkRecord newRecord(String topic, Integer kafkaPartition, Schema keySchema, Object key,
                                Schema valueSchema, Object value, Long timestamp,
                                Iterable<Header> headers) {
        return new InternalSinkRecord(context, topic, kafkaPartition, keySchema, key,
                valueSchema, value, kafkaOffset(), timestamp, timestampType(), headers);
    }
A specialization of {@link SinkRecord} that allows a {@link WorkerSinkTask} to track the
original {@link ConsumerRecord} for each {@link SinkRecord}. It is used internally and not
exposed to connectors.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java