diff --git a/config/schema-registry.properties b/config/schema-registry.properties index 614a762531b..169fcd0806f 100644 --- a/config/schema-registry.properties +++ b/config/schema-registry.properties @@ -19,7 +19,7 @@ # listeners = listener_name://host_name:port # EXAMPLE: # listeners = PLAINTEXT://your.host.name:9092 -listeners=http://0.0.0.0:8081 +listeners=http://0.0.0.0:8081,http://0.0.0.0:8084 # Use this setting to specify the bootstrap servers for your Kafka cluster and it # will be used both for selecting the leader schema registry instance and for storing the data for diff --git a/core/src/main/java/io/confluent/kafka/schemaregistry/rest/SchemaRegistryRestApplication.java b/core/src/main/java/io/confluent/kafka/schemaregistry/rest/SchemaRegistryRestApplication.java index ead64652cd0..58d45469f73 100644 --- a/core/src/main/java/io/confluent/kafka/schemaregistry/rest/SchemaRegistryRestApplication.java +++ b/core/src/main/java/io/confluent/kafka/schemaregistry/rest/SchemaRegistryRestApplication.java @@ -18,6 +18,7 @@ import io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException; import io.confluent.kafka.schemaregistry.rest.extensions.SchemaRegistryResourceExtension; import io.confluent.kafka.schemaregistry.rest.filters.ContextFilter; +import io.confluent.kafka.schemaregistry.rest.filters.PLReqFilter; import io.confluent.kafka.schemaregistry.rest.filters.RestCallMetricFilter; import io.confluent.kafka.schemaregistry.rest.resources.CompatibilityResource; import io.confluent.kafka.schemaregistry.rest.resources.ConfigResource; @@ -107,6 +108,7 @@ public void setupResources(Configurable config, SchemaRegistryConfig schemaRe config.register(new ModeResource(schemaRegistry)); config.register(new ServerMetadataResource(schemaRegistry)); config.register(new ContextFilter()); + config.register(new PLReqFilter()); config.register(new RestCallMetricFilter( schemaRegistry.getMetricsContainer().getApiCallsSuccess(), schemaRegistry.getMetricsContainer().getApiCallsFailure())); diff --git a/core/src/main/java/io/confluent/kafka/schemaregistry/rest/filters/PLReqFilter.java b/core/src/main/java/io/confluent/kafka/schemaregistry/rest/filters/PLReqFilter.java new file mode 100644 index 00000000000..f97b84402df --- /dev/null +++ b/core/src/main/java/io/confluent/kafka/schemaregistry/rest/filters/PLReqFilter.java @@ -0,0 +1,20 @@ +package io.confluent.kafka.schemaregistry.rest.filters; + + +import javax.annotation.Priority; +import javax.ws.rs.Priorities; +import javax.ws.rs.container.ContainerRequestContext; +import javax.ws.rs.container.ContainerRequestFilter; +import javax.ws.rs.container.PreMatching; +import java.io.IOException; + +@PreMatching +@Priority(Priorities.ENTITY_CODER) +public class PLReqFilter implements ContainerRequestFilter { + public PLReqFilter() {} + @Override + public void filter(ContainerRequestContext requestContext) throws IOException { + System.out.println(requestContext.getUriInfo().getRequestUri().getPort()); + System.out.println(requestContext.getUriInfo().getRequestUri().getHost()); + } +}