private Struct applyValueWithSchema(Struct value, Schema updatedSchema) {
        if (value == null) {
            return null;
        }
        Struct updatedValue = new Struct(updatedSchema);
        for (Field field : value.schema().fields()) {
            final Object updatedFieldValue;
            if (field.name().equals(config.field)) {
                updatedFieldValue = convertTimestamp(getFieldValue(value, field), timestampTypeFromSchema(field.schema()));
            } else {
                updatedFieldValue = getFieldValue(value, field);
            }
            updatedValue.put(field.name(), updatedFieldValue);
        }
        return updatedValue;
    }
Convert from the universal java.util.Date format to the type-specific format
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java