6,700 questions
0
votes
0
answers
31
views
Execute blocking task after webflux rest service response is delivered
I want to implement a Rest Service which will return response immediately and continue processing blocking tasks only after response is delivered.
The objectives are
Run blocking & long running ...
- 416
0
votes
1
answer
29
views
spring webflux does not catch exception
I’m trying to catch a thrown exception in a Spring WebFlux controller. When i[0] reaches 3, it enters the handler method and executes the handler, but the returned value is not shown in the output, ...
- 418
Advice
0
votes
1
replies
31
views
Why doesn't R2DBC support features like lazy loading, cascading operations, or dirty checking, which are available in JPA?
I'm working with Spring Data R2DBC in a reactive application and noticed that it doesn't support features like lazy loading, cascading operations, or dirty checking, which are commonly found in JPA ...
- 418
0
votes
2
answers
38
views
Why doesn't Spring Data R2DBC support Jpa features? [closed]
I'm working with Spring Data R2DBC and am curious about why it doesn't support features like lazy loading, cascading operations, or dirty checking, which are commonly used in JPA.
Could someone ...
- 418
1
vote
2
answers
74
views
spring-cloud-gateway-webflux multiple Path predicates return 404
I’m having trouble with Spring Cloud Gateway (WebFlux) when I define multiple Path predicates for a single route.
Here is an example of my configuration in application.yml:
spring:
cloud:
...
0
votes
1
answer
57
views
Spring WebFlux: updating SSL certificate
My application uses the Spring Cloud Gateway so the stack is Spring + WebFlux. When the application starts it use the SSL certificate from the file. But after few weeks the external system is updating ...
0
votes
0
answers
12
views
Reactive Streams stop almost immediately when an ALB is in the mix
I have a spring boot flux endpoint (it takes and returns a flux). If there is no ALB in between, the client requests breeze through with no problems. Streams are closed gracefully on both ends no ...
- 1,424
Advice
2
votes
1
replies
109
views
What's the purpose of spring.http.codecs.max-in-memory-size?
I'm confused with the very existence of the property:
spring.http.codecs.max-in-memory-size=
Limit on the number of bytes that can be buffered whenever the input stream needs to be aggregated. This ...
- 148
-3
votes
0
answers
63
views
OpenTelemetry + ReactiveFeign + Spring WebFlux not propagating traceparent between microservices (header injected but missing in downstream service)
I’m running two Java microservices (A → B) in a Kubernetes cluster (GKE), using:
Spring Boot 3.5 (WebFlux)
ReactiveFeign (Playtika Feign Reactor 4.2.1)
OpenTelemetry Java Agent (2.20.1)
OTLP ...
- 15
0
votes
0
answers
33
views
Spring Webflux Dynamic path control in the filter layer
in my Spring WebFlux project, I cache endpoints with specific annotations at application startup time using the following DTO.
data class ExplorerResult<T>(
override val supportedPaths: Set&...
1
vote
1
answer
88
views
Downloading a large file in spring MVC through Web client
I'm trying to download a large file with with Spring web client without loading an entire file to the memory. I have such service method:
@Override
public StreamingResponseBody download() {
Flux&...
- 143
2
votes
1
answer
79
views
How to find the root cause / exception stacktrace of signal type CANCEL
In doFinally have printed the signal type to finally verify that it was a cancellation (CANCEL). However, this is not captured as part of doOnError as technically cancellation is not part of error.
...
- 1,815
Advice
1
vote
3
replies
39
views
What dependency for Swagger/OpenApi to work in Kotlin and WebFlux Spring Boot application?
I tried a lot of different options, but I cannot find the right dependency that works with Kotlin ans WebFlux simulatneously. Which one should I use? Is it possible to have this setup?
- 123
Best practices
0
votes
1
replies
57
views
Wrap function result in Mono.defer
In which cases does it make sense to wrap the result of a function that returns a Mono in Mono.defer, when assigning it to a variable and using it later?
F.e.
fun getMono(): Mono<Int> // some ...
- 330
1
vote
1
answer
87
views
Measure elapsed time on Spring reactor
I am using spring-webflux version 3.2.x
I want to log the total elapsed time of an whole pipeline execution.
I have found a method elapsed() but I want the total time, but I want the total time, not ...
- 1,355