GitHub user mdedetrich added a comment to the discussion: Artifical back pressure on JDBC projections
Might be a bit of a radical idea, but as a long term solution it seems like r2dbc in conjunction with pekko streams would properly solve this issue (r2dbc implements the reactive streams protocol which mean converting them to pekko-streams is trivial)? There is already pekko-projection-r2dbc albeit its not implemented via pure streams (instead it materializes the transactions prematurely into `Future`). There is an opening for Pekko 2.0.0, we could add an r2dbc module to pekko connectors and pekko-projection-r2dbc could then use that to implement a pure backpressured/streamed implementation for pekko-projections GitHub link: https://github.com/apache/pekko/discussions/2431#discussioncomment-14893593 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
