問題タブ [alpakka]

質問する

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.

201 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
267 参照

rabbitmq - バックプレッシャーが発生したときにrabbitmqでProducerの失敗コールバックを取得する

いくつかのコールバック API を使用して、rabbitmq プロデューサーの失敗したメッセージを見つけたかったのです。rabbitmq を [{rabbit, [{vm_memory_high_watermark, 0.001}]}] で構成しました。多くのメッセージをプッシュしようとしましたが、すべてのメッセージが受け入れられ、 TimeoutException が後で発生し、メッセージが Queueenter code hereに送信されません。キャプチャする方法を教えてください。

メッセージを送信するためのコード:

0 投票する
2 に答える
976 参照

scala - 「withRunningKafka」を使用してEmbedded-Kafka-libを使用してKafka Consumerをテストする方法は?

ここに示すように、組み込みの「withRunningKafka」を介して kafka-server からのすべてのメッセージを消費するコードをテストする必要があります: https://github.com/manub/scalatest-embedded-kafka

  1. 作成された埋め込みプロデューサーを介してトピックにメッセージを送信しようとしました。
  2. そして、プロジェクトのコードを介して、生成されたメッセージ (組み込みプロデューサーによって作成された) を消費しようとしました。

「カスタム プロデューサーとコンシューマーを使用したテスト」は {

ここに問題があります。「OK」を指定しても結果が「完了」になりません。一般的に、消費者をテストする私のロジックは正しいですか?

0 投票する
2 に答える
467 参照

scala - Sqs Akka Stream でメモリ不足

以下のコードは、実行から 15 分以内に EC2 インスタンスで OOO をスローします (java config xms 1024 xmx2G) が、intellij での実行時にエラーをスローしません。

これを 1.0-M3 と 1.0-RC1 の両方で試しました。これの回避策はありますか？

jhat を使用した上位 5 つのオブジェクト作成ヒストグラム -

また、ここで同様の問題を見つけました- https://github.com/akka/alpakka/issues/1588

これを解決するために利用できる代替手段があるかどうか疑問に思っています。


12345678910