reactivemongo as an akka stream sink

[David]

Hello all,

I am encountering some serious back pressure problems when trying to save data consumed from kafka into mongodb.

What is the best way to deal with that?  Is there a way to use reactivemongo as an akka stream sink?

Thanks,

David 

[Cédric Chantepie]

There is no such Sink. A sink with a limited parallelism for a MapAsync calling update can easily be defined. Not sure it help much.