On Fri, 2020-08-28 at 14:26 +0530, SenthilKumar K wrote: > Hello Experts, We have been running Apache Async Http Client in > Product to > Post Events to Splunk & Datadog Third-Party Systems. Most of the > times it > works well but when there was some Connection Closed Exception > happens for > a particular endpoint, Client is continuously getting task cancelled > error > which is resulting in the data loss from our side. > > > Context: > We run the AsyncClient in Container, Configuration of Container: 2 > CPUs, 7 > GB memory & 1GB disk. > > The moment AsyncHttpClient receives " Failed to post log to > destination > EndPoint : https://abcde.com/v1/input/jskjdhk , *Error Msg: > Connection > closed " *the all subsequent calls getting task cancelled by http > client. > > What's wrong with the client configuration? Am i missing something? > > Client Settings: > > public static final RequestConfig.Builder requestConfigBuilder = > RequestConfig.custom() > .setConnectTimeout(DEFAULT_CONNECT_TIMEOUT_MILLIS) // 10 > seconds > .setSocketTimeout(DEFAULT_SOCKET_TIMEOUT_MILLIS) // 10 > seconds > > .setConnectionRequestTimeout(DEFAULT_CONNECTION_REQUEST_TIMEOUT_MILLI > S); // > 10 seconds > > public static final ConnectionConfig connectionConfig = > ConnectionConfig.custom() > .setBufferSize(DEFAULT_BUFFER_SIZE) > .setMessageConstraints(messageConstraints) > .setFragmentSizeHint(DEFAULT_BUFFER_SIZE) > .build(); > > final PoolingNHttpClientConnectionManager mgr = new > PoolingNHttpClientConnectionManager(ioreactor, registry); > mgr.setDefaultConnectionConfig(connectionConfig); > mgr.setMaxTotal(DEFAULT_MAX_CONN_TOTAL); // 500 > mgr.setDefaultMaxPerRoute(DEFAULT_MAX_CONN_PER_ROUTE); // 25 > mgr.closeExpiredConnections(); > > final HttpAsyncClientBuilder httpClientBuilder = > HttpAsyncClientBuilder.create() > > .setDefaultRequestConfig(requestConfigBuilder.build()) > .setMaxConnPerRoute(DEFAULT_MAX_CONN_PER_ROU > TE) > //25 > .setMaxConnTotal(DEFAULT_MAX_CONN_TOTAL)//50 > 0 > .setDefaultConnectionConfig(connectionConfig > ) > .setConnectionManager(mgr) > .setSSLContext(getSSLContext()) > .setSSLHostnameVerifier(hostNameVerifier) > .disableConnectionState() > .disableAuthCaching() > .disableCookieManagement() > .useSystemProperties(); > CloseableHttpAsyncClient httpClient = httpClientBuilder.build(); > httpClient.start(); > > > <dependency> > <groupId>org.apache.httpcomponents</groupId> > <artifactId>*httpasyncclient*</artifactId> > <version>4.1.4</version> > </dependency> > > --Senthil
Please post a _complete_ context / wire log of the session. Oleg --------------------------------------------------------------------- To unsubscribe, e-mail: httpclient-users-unsubscr...@hc.apache.org For additional commands, e-mail: httpclient-users-h...@hc.apache.org
