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 and Description
SchemaRegistryRestApplication(Properties props)
SchemaRegistryRestApplication(SchemaRegistryConfig config)

Method Summary

Modifier and Type	Method and Description
void	configureBaseApplication(javax.ws.rs.core.Configurable<?> config, Map<String,String> metricTags)
org.eclipse.jetty.server.Handler	configureHandler()
protected void	configurePreResourceHandling(org.eclipse.jetty.servlet.ServletContextHandler context)
protected com.fasterxml.jackson.databind.ObjectMapper	getJsonMapper()
protected org.eclipse.jetty.util.resource.ResourceCollection	getStaticResources()
protected KafkaSchemaRegistry	initSchemaRegistry(SchemaRegistryConfig config)
static void	logAllHandlers(org.eclipse.jetty.server.Handler handler)
void	onShutdown()
void	postServerStart()
void	registerInitResourceExtensions(javax.ws.rs.core.Configurable<?> config, SchemaRegistryConfig schemaRegistryConfig)
KafkaSchemaRegistry	schemaRegistry()
void	setupResources(javax.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 Detail

SchemaRegistryRestApplication

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

Throws:

io.confluent.rest.RestConfigException

SchemaRegistryRestApplication

public SchemaRegistryRestApplication(SchemaRegistryConfig config)

Method Detail

getJsonMapper

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

Overrides:

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

configurePreResourceHandling

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

Overrides:

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

initSchemaRegistry

protected KafkaSchemaRegistry initSchemaRegistry(SchemaRegistryConfig config)

postServerStart

public void postServerStart()

configureBaseApplication

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

Overrides:

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

setupResources

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

Specified by:

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

registerInitResourceExtensions

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

getStaticResources

protected org.eclipse.jetty.util.resource.ResourceCollection 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 KafkaSchemaRegistry schemaRegistry()