Akka 流：使用持久化队列或事件源

Question

在 Akka 流应用程序中，如果应用程序 crashes/node 宕机，我 运行 有丢失正在运行的消息的风险。

如何确保我们不会丢失消息并在应用程序恢复后播放这些消息。

在我的应用程序中，mapAsyns 执行 IO 调用和一些次要的 CPU 绑定任务。

在纯 Akka 应用程序中，我将选择持久队列或事件源。但是在 Akka 流的情况下，由于我无法访问底层队列，我如何确保流中的消息不会丢失？

Answer 1

您需要检查流接收器，然后在崩溃时根据上次成功的检查点恢复源。您可以使用您提到的持久队列或事件源来执行检查点和恢复。