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

Class ContextsResource

java.lang.Object

io.confluent.kafka.schemaregistry.rest.resources.ContextsResource

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	apiTag

Constructor Summary

Constructors

Constructor	Description
ContextsResource(SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method	Description
void	deleteContext(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String delimitedContext)
List<String>	listContexts(int offset, int limit, String contextPrefix)

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

ContextsResource

@Inject
public ContextsResource(SchemaRegistry schemaRegistry)

Method Details

listContexts

@GET
@DocumentedName("getAllContexts")
@PerformanceMetric("contexts.list")
public List<String> listContexts(@DefaultValue("0") @QueryParam("offset")
 int offset,
 @DefaultValue("-1") @QueryParam("limit")
 int limit,
 @QueryParam("contextPrefix")
 String contextPrefix)

deleteContext

@DELETE
@Path("/{context}")
@DocumentedName("deleteContext")
@PerformanceMetric("context.delete")
public void deleteContext(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @PathParam("context")
 String delimitedContext)