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

Class ConfigResource

java.lang.Object

io.confluent.kafka.schemaregistry.rest.resources.ConfigResource

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	apiTag

Constructor Summary

Constructors

Constructor	Description
ConfigResource(SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method	Description
void	deleteSubjectConfig(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String subject)
void	deleteTopLevelConfig(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers)
Config	getSubjectLevelConfig(String subject, boolean defaultToGlobal)
Config	getTopLevelConfig(boolean defaultToGlobal)
ConfigUpdateRequest	updateSubjectLevelConfig(String subject, jakarta.ws.rs.core.HttpHeaders headers, @NotNull ConfigUpdateRequest request)
ConfigUpdateRequest	updateTopLevelConfig(jakarta.ws.rs.core.HttpHeaders headers, @NotNull ConfigUpdateRequest 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

ConfigResource

@Inject
public ConfigResource(SchemaRegistry schemaRegistry)

Method Details

updateSubjectLevelConfig

@Path("/{subject}")
@PUT
@DocumentedName("updateSubjectConfig")
@PerformanceMetric("config.update-subject")
public ConfigUpdateRequest updateSubjectLevelConfig(@PathParam("subject")
 String subject,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @NotNull
 @NotNull ConfigUpdateRequest request)

getSubjectLevelConfig

@Path("/{subject}")
@GET
@DocumentedName("getSubjectConfig")
@PerformanceMetric("config.get-subject")
public Config getSubjectLevelConfig(@PathParam("subject")
 String subject,
 @QueryParam("defaultToGlobal")
 boolean defaultToGlobal)

updateTopLevelConfig

@PUT
@DocumentedName("updateGlobalConfig")
@PerformanceMetric("config.update-global")
public ConfigUpdateRequest updateTopLevelConfig(@Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @NotNull
 @NotNull ConfigUpdateRequest request)

getTopLevelConfig

@GET
@DocumentedName("getGlobalConfig")
@PerformanceMetric("config.get-global")
public Config getTopLevelConfig(@QueryParam("defaultToGlobal")
 boolean defaultToGlobal)

deleteTopLevelConfig

@DELETE
@DocumentedName("deleteGlobalConfig")
@PerformanceMetric("config.delete-global")
public void deleteTopLevelConfig(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers)

deleteSubjectConfig

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