Load balanced Spring WebClient + setting Netty read and connect timeouts

gistfile1.txt

// https://projectreactor.io/docs/netty/snapshot/reference/index.html

@Bean
@LoadBalanced
public WebClient.Builder loadBalancedWebClientBuilder(ExchangeStrategies exchangeStrategies, ClientHttpConnector clientHttpConnector) {
    return WebClient.builder()
    .clientConnector(clientHttpConnector)
//    .filter(new LoadBalancerExchangeFilterFunction(loadBalancerClient)) // in case without @LoadBalanced annotation, loadBalancerClient comes from context
    .exchangeStrategies(exchangeStrategies);
}

@Bean
public ExchangeStrategies exchangeStrategies() {
        return ExchangeStrategies.builder()
            .codecs(configurer -> configurer
                .defaultCodecs()
                .maxInMemorySize(1024 * 1024 * 2)) // default is 256KB
            .build();
}

@Bean
public ClientHttpConnector clientHttpConnector(TcpClient tcpClient) {
    return new ReactorClientHttpConnector(HttpClient.from(tcpClient));
}

@Bean
public TcpClient tcpClient(NettyConfig nettyConfig) {
    return TcpClient.create()
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyConfig.getConnectTimeout())
        .doOnConnected(connection -> connection.addHandlerLast(new ReadTimeoutHandler(nettyConfig.getReadTimeout(), TimeUnit.MILLISECONDS)));
    }