@Override
        protected R newRecord(R record, Schema updatedSchema) {
            Object updatedKey = updateSchemaIn(record.key(), updatedSchema);
            return record.newRecord(record.topic(), record.kafkaPartition(), updatedSchema, updatedKey, record.valueSchema(), record.value(), record.timestamp());
        }
Set the schema name, version or both on the record's key schema.
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java