ConnectionClosedException with R2DBC

[ali koudri]

Hi,

I am currently using R2DBC connector with Postgresql. Although my configuration seems good and everything is working fine when I perform a request, I have always the same error message at each request on the database:

[reactor-tcp-epoll-1] ERROR reactor.core.publisher.Operators - Operator called default onErrorDropped
io.r2dbc.postgresql.client.ReactorNettyClient$PostgresConnectionClosedException: Connection closed

I have not found anything on the internet regarding this issue. If anybody has any clue on this topic, it would be very helpful ! Thx.

[Michael McMahon]

I had a similar issue for Oracle R2DBC: https://github.com/oracle/oracle-r2dbc/issues/133

In my case, this happened when I combined concatDelayError and doOnCancel operators: https://github.com/oracle/oracle-r2dbc/pull/134

To fix this, I replaced concatDelayError with a usingWhen operator: https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#usingWhen-org.reactivestreams.Publisher-java.util.function.Function-java.util.function.Function-

Hope this helps!

[ali koudri]

Thank you very much Michael. I will let you know if it helped.

Regards,

A.