From 107dc98476ef6be61294e964e6e5498e07467308 Mon Sep 17 00:00:00 2001 From: Sebastian Schepens Date: Wed, 22 Feb 2017 10:11:05 -0300 Subject: [PATCH] Enable gzip for broker web service --- .../src/main/java/com/yahoo/pulsar/broker/web/WebService.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pulsar-broker/src/main/java/com/yahoo/pulsar/broker/web/WebService.java b/pulsar-broker/src/main/java/com/yahoo/pulsar/broker/web/WebService.java index f92d96c12ec7c..ac89208c1d2d6 100644 --- a/pulsar-broker/src/main/java/com/yahoo/pulsar/broker/web/WebService.java +++ b/pulsar-broker/src/main/java/com/yahoo/pulsar/broker/web/WebService.java @@ -42,7 +42,9 @@ import org.eclipse.jetty.util.resource.Resource; import org.eclipse.jetty.util.ssl.SslContextFactory; import org.eclipse.jetty.util.thread.ExecutorThreadPool; +import org.glassfish.jersey.message.GZipEncoder; import org.glassfish.jersey.server.ResourceConfig; +import org.glassfish.jersey.server.filter.EncodingFilter; import org.glassfish.jersey.servlet.ServletContainer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -125,6 +127,7 @@ public void addRestResources(String basePath, String javaPackages, boolean requi ResourceConfig config = new ResourceConfig(); config.packages("jersey.config.server.provider.packages", javaPackages); config.register(provider); + EncodingFilter.enableFor(config, GZipEncoder.class); ServletHolder servletHolder = new ServletHolder(new ServletContainer(config)); servletHolder.setAsyncSupported(true); addServlet(basePath, servletHolder, requiresAuthentication);