Jersey client connection reuse with chunked gzip response

[apurv-goel]

Hi,
I am trying to use a Jersey (3.x) client with ApacheConnector but I observed that in case a chunked gzip response is received. the connection gets closed as soon as the response is read. The connection is not reused even after configuring a connection pool, keep-alive strategy and reuse strategy.

The request seems to be aborted in the following code as it is chunked and because the connection was not yet released, it is shutdown.

jersey/connectors/apache-connector/src/main/java/org/glassfish/jersey/apache/connector/ApacheConnectionClosingStrategy.java

Line 75 in b128e9c

request.abort();

However this seems to work correctly with non-gzipped chunked responses. Is Jersey not expected to work with gzip chunked responses? Or can I do something to make it work correctly here?

Reference Code:

  PoolingHttpClientConnectionManager connectionManager2 = new PoolingHttpClientConnectionManager();
    connectionManager2.setMaxTotal(100); // Maximum total connections
    connectionManager2.setDefaultMaxPerRoute(100); // Maximum connections per route

  final ClientConfig clientConfig = new ClientConfig();
  clientConfig.connectorProvider(new ApacheConnectorProvider());
  clientConfig.property(ApacheClientProperties.CONNECTION_MANAGER, connectionManager2);
  clientConfig.property(ApacheClientProperties.KEEPALIVE_STRATEGY,
    (ConnectionKeepAliveStrategy) (response, context) -> 60000);
  clientConfig.property(ApacheClientProperties.REUSE_STRATEGY,
    (ConnectionReuseStrategy) (response, context) -> true);

  // Build the Jersey client
  JERSEY_CLIENT = ClientBuilder.newClient(clientConfig);

  final var request = JERSEY_CLIENT.target(getRequestUri()).request(MediaType.APPLICATION_JSON);
  var response = request.post(Entity.entity(JsonUtil.toJsonString(requestBody), MediaType.APPLICATION_JSON));
  var responseEntity = response.readEntity(String.class); // request abort and connection shutdown happens at this call.

I tried reading entity with InputStream.class instead of String.class as well but that also seems to produce the same result even if I close that InputStream. Also, seeing this issue with both Jersey 3 and Jersey 2 if that helps.