Package io.confluent.kafka.schemaregistry.rest.resources

Class CompatibilityResource

java.lang.Object

io.confluent.kafka.schemaregistry.rest.resources.CompatibilityResource

@Path("/compatibility")
@Produces({"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json; qs=0.9","application/json; qs=0.5"})
@Consumes({"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json","application/json","application/octet-stream"})
public class CompatibilityResource
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	apiTag

Constructor Summary

Constructors

Constructor	Description
CompatibilityResource(SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method	Description
void	testCompatibilityBySubjectName(jakarta.ws.rs.container.AsyncResponse asyncResponse, String subject, String version, boolean normalize, @NotNull RegisterSchemaRequest request, boolean verbose)
void	testCompatibilityForSubject(jakarta.ws.rs.container.AsyncResponse asyncResponse, String subject, boolean normalize, @NotNull RegisterSchemaRequest request, boolean verbose)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

apiTag

public static final String apiTag

See Also:

• Constant Field Values

Constructor Details

CompatibilityResource

@Inject
public CompatibilityResource(SchemaRegistry schemaRegistry)

Method Details

testCompatibilityBySubjectName

@POST
@Path("/subjects/{subject}/versions/{version}")
@DocumentedName("testVersionCompatibility")
@PerformanceMetric("compatibility.subjects.versions.verify")
public void testCompatibilityBySubjectName(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("subject")
 String subject,
 @PathParam("version")
 String version,
 @QueryParam("normalize")
 boolean normalize,
 @NotNull
 @NotNull RegisterSchemaRequest request,
 @QueryParam("verbose")
 boolean verbose)

testCompatibilityForSubject

@POST
@Path("/subjects/{subject}/versions")
@DocumentedName("testSubjectCompatibility")
@PerformanceMetric("compatibility.subjects.versions.verify")
public void testCompatibilityForSubject(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("subject")
 String subject,
 @QueryParam("normalize")
 boolean normalize,
 @NotNull
 @NotNull RegisterSchemaRequest request,
 @QueryParam("verbose")
 boolean verbose)