Akkaストリーム：永続性キューまたはイベントソースの使用

Question

Akkaストリームアプリケーションでは、アプリケーションがクラッシュしたりノードがダウンすると、機内メッセージを失う危険があります。

私たちがメッセージを失わないように、またアプリケーションが戻ったときに再生されるようにするためにできることは何ですか？

私のアプリケーションでは、mapAsynsはIOコールとマイナーなCPUバインドタスクを実行します。

純粋なAkkaアプリケーションでは、永続的なキューまたはイベントソースのいずれかを使用します。しかし、Akkaストリームの場合、基になるキューにアクセスできないので、ストリーム内のメッセージが失われないようにするにはどうすればよいですか？

Answer 1

ストリームシンクをチェックポイントし、最後に成功したチェックポイントに基づいてソースがクラッシュした場合は、そのソースを再開する必要があります。チェックポイントを実行して、永続的なキューまたはイベントのソースを使用して再開することができます。