io.confluent.kafka.schemaregistry.rest.resources

Class SubjectsResource

java.lang.Object

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

@Path(value="/subjects")
 @Produces(value={"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json; qs=0.9","application/json; qs=0.5"})
 @Consumes(value={"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 and Description
static String	apiTag

Constructor Summary

Constructors

Constructor and Description
SubjectsResource(KafkaSchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method and Description
void	deleteSubject(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String subject, boolean permanentDelete)
void	getLatestWithMetadata(javax.ws.rs.container.AsyncResponse asyncResponse, String subject, List<String> keys, List<String> values, String format, boolean lookupDeletedSchema)
@Valid Set<String>	list(String subjectPrefix, boolean lookupDeletedSubjects, boolean lookupDeletedOnlySubjects)
void	lookUpSchemaUnderSubject(javax.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 Detail

apiTag

public static final String apiTag

See Also:

Constant Field Values

Constructor Detail

SubjectsResource

public SubjectsResource(KafkaSchemaRegistry schemaRegistry)

Method Detail

lookUpSchemaUnderSubject

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

getLatestWithMetadata

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

list

@GET
 @DocumentedName(value="getAllSubjects")
 @Valid
 @PerformanceMetric(value="subjects.list")
public @Valid Set<String> list(@DefaultValue(value=":*:") @QueryParam(value="subjectPrefix")
                                                                                                                                String subjectPrefix,
                                                                                                                                @QueryParam(value="deleted")
                                                                                                                                boolean lookupDeletedSubjects,
                                                                                                                                @QueryParam(value="deletedOnly")
                                                                                                                                boolean lookupDeletedOnlySubjects)

deleteSubject

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