February 2018
Intermediate to advanced
552 pages
13h 46m
English
In Akka Toolkit, the Akka Streams API uses Dynamic pull/push backpressure model to solve the fast streaming data issues that we discussed in the previous section.
In dynamic pull/push mode, sometimes it uses a pull-based model, and sometimes it uses a push-based model.
If a System has a Fast Producer/Slow Consumer, this model uses a pull-based approach, which means Consumer always requests how many messages (data elements) it can process to Producer, then only that Producer sends that many messages to Consumer:

As shown in the preceding diagram, Consumer sends a Request of five messages to Producer. Then, Producer ...
Read now
Unlock full access