in core/src/main/java/org/apache/rocketmq/schema/registry/core/api/v1/SchemaController.java [296:314]
public UpdateSchemaResponse updateSchema(
@ApiParam(value = "The cluster of the subject", required = true)
@PathVariable(value = "cluster-name") final String cluster,
@ApiParam(value = "The tenant of the schema", required = true)
@PathVariable(value = "tenant-name") final String tenant,
@ApiParam(value = "The subject of the schema", required = true)
@PathVariable(value = "subject-name") final String subject,
@ApiParam(value = "The name of the schema", required = true)
@PathVariable(value = "schema-name") final String schemaName,
@ApiParam(value = "The schema detail", required = true)
@RequestBody final UpdateSchemaRequest updateSchemaRequest
) {
QualifiedName name = new QualifiedName(cluster, tenant, subject, schemaName);
return this.requestProcessor.processRequest(
name,
"updateSchema",
() -> this.schemaService.update(name, updateSchemaRequest)
);
}