問題タブ [akka-supervision]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Akka - 子に例外が発生した後、親が子にメッセージを送信する方法
アクターに一度に1 つのメッセージparentを送信するアクターがあると仮定します。child
子プロセスが現在のメッセージの処理を完了すると、新しいメッセージを子プロセスに送信することを親に通知します。
子が特定のメッセージでクラッシュした場合でもこのループを維持するために、SupervisorStrategy を親に追加しました。
その考えは、子供に何が起こっても再開し、親は次のメッセージを送ることができるということです。
しかし、次のメッセージを送信するために、親はどのようにしてエラーが発生したかを知るのでしょうか?
子供に何かが起こった親にとっての引き金は何ですか？
オーバーライドする必要がある「onChileError」メソッドのようなものはありますか?
(Java over Scala の例を評価します)
ありがとう。
akka - Akka Kafka ストリーム監視戦略が機能しない
私は Akka Streams Kafka アプリケーションを実行しています。ブローカが停止し、ストリーム コンシューマが停止タイムアウト後に停止した場合、スーパーバイザがコンシューマを再起動できるように、ストリーム コンシューマに監視戦略を組み込みたいと考えています。
ここに私の完全なコードがあります:
UserEventStream:
StreamProcessorSupervisor(これはクラスのスーパーバイザー クラスですUserEventStream):
App(メイン アプリケーション クラス):
application.conf:
アプリケーションを実行した後、意図的に Kafka ブローカーを強制終了しましたが、30 秒後に攻撃者がポイズン ピルを送信して自身を停止していることに気付きました。BackoffSupervisorしかし不思議なことに作戦通りに再起動しない。
ここで何が問題になる可能性がありますか?