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

Class SubjectsResource

java.lang.Object

io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource

@Path("/subjects")
@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 SubjectsResource
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	apiTag

Constructor Summary

Constructors

Constructor	Description
SubjectsResource(SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method	Description
void	deleteSubject(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String subject, boolean permanentDelete)
void	getLatestWithMetadata(jakarta.ws.rs.container.AsyncResponse asyncResponse, String subject, List<String> keys, List<String> values, String format, boolean lookupDeletedSchema)
@Valid Set<String>	list(String subjectPrefix, int offset, int limit, boolean lookupDeletedSubjects, boolean lookupDeletedOnlySubjects)
void	lookUpSchemaUnderSubject(jakarta.ws.rs.container.AsyncResponse asyncResponse, String subject, boolean normalize, String format, boolean lookupDeletedSchema, @NotNull RegisterSchemaRequest request)

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

SubjectsResource

@Inject
public SubjectsResource(SchemaRegistry schemaRegistry)

Method Details

lookUpSchemaUnderSubject

@POST
@DocumentedName("lookUpSchemaUnderSubject")
@Path("/{subject}")
@PerformanceMetric("subjects.get-schema")
public void lookUpSchemaUnderSubject(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("subject")
 String subject,
 @QueryParam("normalize")
 boolean normalize,
 @DefaultValue("") @QueryParam("format")
 String format,
 @QueryParam("deleted")
 boolean lookupDeletedSchema,
 @NotNull
 @NotNull RegisterSchemaRequest request)

getLatestWithMetadata

@GET
@DocumentedName("getLatestWithMetadata")
@Path("/{subject}/metadata")
@PerformanceMetric("subjects.get-latest-with-metadata")
public void getLatestWithMetadata(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("subject")
 String subject,
 @QueryParam("key")
 List<String> keys,
 @QueryParam("value")
 List<String> values,
 @DefaultValue("") @QueryParam("format")
 String format,
 @QueryParam("deleted")
 boolean lookupDeletedSchema)

list

@GET
@DocumentedName("getAllSubjects")
@Valid
@PerformanceMetric("subjects.list")
public @Valid Set<String> list(@DefaultValue(":*:") @QueryParam("subjectPrefix")
 String subjectPrefix,
 @DefaultValue("0") @QueryParam("offset")
 int offset,
 @DefaultValue("-1") @QueryParam("limit")
 int limit,
 @QueryParam("deleted")
 boolean lookupDeletedSubjects,
 @QueryParam("deletedOnly")
 boolean lookupDeletedOnlySubjects)

deleteSubject

@DELETE
@DocumentedName("deleteSubject")
@Path("/{subject}")
@PerformanceMetric("subjects.delete-subject")
public void deleteSubject(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @PathParam("subject")
 String subject,
 @QueryParam("permanent")
 boolean permanentDelete)