Questions tagged [reactor-netty]
Reactor over the Netty client server framework
reactor-netty
536
questions
0
votes
0
answers
36
views
Netty blocking spring integration workers
Currently I’m working on a spring integration service that uses webClient with Netty for http calls
The problem that I'm facing occurs when spring integration goes to a channel and while it is ...
- 15
1
vote
0
answers
36
views
WebClientRequestException: Pending acquire queue has reached its maximum size of XX
for ilustration purposes I have this code:
// remote Echo server
@GetMapping("echo")
public Mono<String> echo(){
return Mono.just("echo");
}
// client 1 ...
- 1,917
0
votes
0
answers
43
views
AWS SDK Https calls from EKS pod slower than ECS
I have a Spring Boot reactive application running on both ECS and EKS, with similar hardware configuration (cpu:6 and memory 16G).
This applications has a REST API endpoint that updates multiple ...
- 2,747
1
vote
0
answers
27
views
Are there any spring properties to set defaults for spring webclient?
I was wondering if there exists something like
spring.webclient.connectionPoolSize=100
spring.webclient.readTimeOut=1s
and other similar properties in the same way we configure default kafka or jdbc ...
0
votes
0
answers
18
views
ReadTimeoutException on webflux POST request but data on the wire is received
I have a WebClient configured as follows:
webClient = webClientBuilder
.baseUrl(baseUrl)
.clientConnector(new ReactorClientHttpConnector(
...
- 394
0
votes
0
answers
40
views
LocalAddress setup for reactor-netty client and server
Cant find the way to setup local transport for reactor-netty client and server
I've tried to simply provide bindAddress as LocalAdress("some") but has no luck with
java.nio.channels....
- 1
1
vote
0
answers
40
views
How can I turn off reactor HTTP logging on an Azure Function app
How can I turn off reactor HTTP logging on an Azure Function app?
I added a KeyVault SecretClient class instance , which is creating thousands and thousands of logs around reactor.http.
This host.json ...
- 29.3k
0
votes
1
answer
52
views
Spring's reactive WebClient does not fetch response body but Postman does
I have simple spring-boot 3.3 web-flux server which runs on Netty with method:
@GetMapping("/{id}")
public Mono<DataEntity> getData(@PathVariable("id") String extId) {...
0
votes
1
answer
104
views
Http Connection Management In Spring Cloud Gateway / Reactor Netty
We use Spring Cloud Gateway (Spring Boot 2.0) to route(POST) request to different external customer REST endpoint (along with filters).
Most of the time routing is ok in production, only certain times ...
- 185
1
vote
0
answers
68
views
LEAK: ByteBuf.release() was not called before it's garbage-collected in spring webflux project
I keep getting leakbuffer error just by invoking my rest api, sometimes connection closed exception. I am not using any bytebuff exclusively in my code. I have rest api, on calling it should fetch ...
- 21
0
votes
1
answer
64
views
Netty Server not processing HTTP Requests after using Server Bootstrap for customizing
I have a spring reactive-based Microservice which is using Netty Server version 4.1.101.Final. It was working completely fine and processing all the HTTP requests that I fired. Now I want to catch ...
0
votes
0
answers
52
views
How to resolve consistently occuring 502 errors in Spring Reactive based microservice using Netty Server
I have Spring Reactive based microservice which is using Netty Server with version 4.1.101.Final.The complete architecture and flow of my microservice is:
API Gateway -> Load Balancer -> PCF (Go ...
0
votes
0
answers
36
views
[SpringCloudGateway]: Netty HttpClient failed to connect with SSLHandshakeException after establishing HTTPS connection with endpoint
We have built API Gateway application using Spring Cloud Gateway 4.0 (on webflux) framework and Azul Zulu OpendJDK 17. The application is able to intercept incoming request and redirect it to the ...
1
vote
1
answer
47
views
In Spring Webflux, is it thread safe to initialized a variable and use it later inside a Mono pipeline?
Say I have a @RestController with a @GetMapping with the following mono pipeline. MyRequest and MyResponse just has a String field called id.
Is it correct to use id into the Mono pipeline without ...
- 47
0
votes
0
answers
142
views
Connection Closed BEFORE Send Operation After Upgrading Spring Boot to 3.2.4
I've recently upgraded my Spring Boot application from version 2.5 to 3.2.4. After deploying the updated application to production, I started receiving the following logs excessively:
r.n.c....
- 748