Package io.confluent.kafka.schemaregistry.rest

Class SchemaRegistryRestApplication

java.lang.Object

io.confluent.rest.Application<SchemaRegistryConfig>

io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication

public class SchemaRegistryRestApplication
extends io.confluent.rest.Application<SchemaRegistryConfig>

Field Summary

Fields inherited from class io.confluent.rest.Application

config, jetty429MetricsListener, metrics, requestLog, resourceExtensions, server, shutdownLatch

Constructor Summary

Constructors

Constructor	Description
SchemaRegistryRestApplication(SchemaRegistryConfig config)
SchemaRegistryRestApplication(SchemaRegistryConfig config, io.spiffe.workloadapi.X509Source x509Source)
SchemaRegistryRestApplication(Properties props)

Method Summary

Modifier and Type	Method	Description
void	configureBaseApplication(jakarta.ws.rs.core.Configurable<?> config, Map<String,String> metricTags)
org.eclipse.jetty.server.Handler	configureHandler()
protected void	configurePreResourceHandling(org.eclipse.jetty.ee10.servlet.ServletContextHandler context)
protected com.fasterxml.jackson.databind.ObjectMapper	getJsonMapper()
protected Collection<org.eclipse.jetty.util.resource.Resource>	getStaticResources()
protected SchemaRegistry	initSchemaRegistry(SchemaRegistryConfig config)
static void	logAllHandlers(org.eclipse.jetty.server.Handler handler)
void	onShutdown()
void	postServerStart()
void	registerInitResourceExtensions(jakarta.ws.rs.core.Configurable<?> config, SchemaRegistryConfig schemaRegistryConfig)
SchemaRegistry	schemaRegistry()
void	setupResources(jakarta.ws.rs.core.Configurable<?> config, SchemaRegistryConfig schemaRegistryConfig)

Methods inherited from class io.confluent.rest.Application

addGlobalDosfilterListener, addNonGlobalDosfilterListener, configureBaseApplication, configureHttpResponseHeaderFilter, configureMetrics, configurePostResourceHandling, configureSecurityHandler, configureWebSocketHandler, configureWebSocketPostResourceHandling, createAuthenticator, createBasicSecurityHandler, createBearerSecurityHandler, createGlobalAuthConstraint, createIdentityService, createLoginService, createSecurityHandler, createServer, getConfiguration, getListenerName, getMetrics, getMetricsTags, getPath, getSslContextFactory, join, parseListeners, parseListToMap, registerExceptionMappers, registerFeatures, registerJsonProvider, registerWebSocketEndpoints, requestLogFormat, start, stop, wrapWithGzipHandler

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaRegistryRestApplication

public SchemaRegistryRestApplication(Properties props)
                              throws io.confluent.rest.RestConfigException

Throws:

io.confluent.rest.RestConfigException

SchemaRegistryRestApplication

public SchemaRegistryRestApplication(SchemaRegistryConfig config)

SchemaRegistryRestApplication

public SchemaRegistryRestApplication(SchemaRegistryConfig config,
 io.spiffe.workloadapi.X509Source x509Source)

Method Details

getJsonMapper

protected com.fasterxml.jackson.databind.ObjectMapper getJsonMapper()

Overrides:

getJsonMapper in class io.confluent.rest.Application<SchemaRegistryConfig>

configurePreResourceHandling

protected void configurePreResourceHandling(org.eclipse.jetty.ee10.servlet.ServletContextHandler context)

Overrides:

configurePreResourceHandling in class io.confluent.rest.Application<SchemaRegistryConfig>

initSchemaRegistry

protected SchemaRegistry initSchemaRegistry(SchemaRegistryConfig config)

postServerStart

public void postServerStart()

configureBaseApplication

public void configureBaseApplication(jakarta.ws.rs.core.Configurable<?> config,
 Map<String,String> metricTags)

Overrides:

configureBaseApplication in class io.confluent.rest.Application<SchemaRegistryConfig>

setupResources

public void setupResources(jakarta.ws.rs.core.Configurable<?> config,
 SchemaRegistryConfig schemaRegistryConfig)

Specified by:

setupResources in class io.confluent.rest.Application<SchemaRegistryConfig>

registerInitResourceExtensions

public void registerInitResourceExtensions(jakarta.ws.rs.core.Configurable<?> config,
 SchemaRegistryConfig schemaRegistryConfig)

getStaticResources

protected Collection<org.eclipse.jetty.util.resource.Resource> getStaticResources()

Overrides:

getStaticResources in class io.confluent.rest.Application<SchemaRegistryConfig>

onShutdown

public void onShutdown()

Overrides:

onShutdown in class io.confluent.rest.Application<SchemaRegistryConfig>

configureHandler

public org.eclipse.jetty.server.Handler configureHandler()

Overrides:

configureHandler in class io.confluent.rest.Application<SchemaRegistryConfig>

logAllHandlers

public static void logAllHandlers(org.eclipse.jetty.server.Handler handler)

schemaRegistry

public SchemaRegistry schemaRegistry()