backpressure

0熱

1答えて

私はKafkaからの入力を受け取り、シャードされた俳優とのデータを処理してKafkaに出力するAkkaアプリケーションを作成しました。しかし、いくつかの場面でシャードの領域は、負荷を処理することができない、と私は得る：おそらくリモート接続をフラッディングを回避するためにフロー制御を実装する必要があります。このチェーン/フローにどのようにバックプレッシャーを実装できますか？カフカ消費者 -

0熱

1答えて

観測可能なサポートレスキュープル

私はかなり基本的な質問であると私はしばらくの間苦労してきました。私はFlowableを持っています。これは、ネットワークからアイテムの束を取り出し、それらを放出します。 Flowable .create(new FlowableOnSubscribe<Item>() { @Override public void subscribe(FlowableEmitte

0熱

1答えて

RxJava2を使用して生成関数を使用してフロアブルを作成する

バックプレッシャを実装したカスタムFlowableを作成する必要があります。私はある種のページングを達成しようとしています。つまり、下流側で5つのアイテムをリクエストすると、アイテム0〜5を「データソースに尋ねる」ことを意味します。その後、下流で別の5が必要になると、アイテム5〜10が取得され、返されます。 Flowable.generateメソッドを使用するのが最善の方法ですが、実際には（私が知

3熱

1答えて

複数のJVMを含むAkkaストリームの背圧を維持する方法

Akka 2.4.16以降、Reactive Streamsの「リモート」実装はありません。この仕様では、単一のJVM上で実行されるストリームに焦点を当てています。しかし、背圧を維持しながら、処理のために別のJVMを使用することを考慮してください。アイデアは、ストリームを実行するユーザーインターフェイスを提供するメインアプリケーションを持つことです。たとえば、このストリームには、別のマシンで実行

4熱

1答えて

RxJava2観測可能な背圧

最近、私は背圧がどのように働くのか分かりません。私は小さなテストをしたと私はそれがMissingBackpressureException例外で失敗する必要があることを期待：それはMissingBackpressureExceptionを生成しないのはなぜ Emit: 0 Emit: 1 Emit: 2 ... Emit: 10000 Processed:0 Processed:1

3熱

1答えて

バックプレッシャーの影響を受けないソースを作成する方法

conflateのようないくつかのAkkaストリーム機能をテストしたいと思います。このためには、単純な単体テストで背圧の影響を受けないソースを構築する必要があります。ナイーブな試みのように Source.tick(1.milli, 1.milli, "tick").map(_ => Random.nextDouble()) バックプレッシャーのために機能しません。 HTTP経由のOTOHはおそ

3熱

1答えて

Rxjavaでは「バックプレッシャー」は何を意味していますか？

私はRxJavaの初心者です。 "BackPressure"の意味が不思議です。プロデューサーが消費者の背中に圧力をかけているということですか？これは、消費者が生産者に圧力をかけているということですか？（逆方向の圧力）

1熱

1答えて

永続アクタを使用したAkka Shardingの背圧

Akkaストリーム背圧モデルまたは永続アクタを使用したakkaシャーディングを使用するためのものはありますか？私には問題があるため、永続的なアクターを持つAkkShardingクラスタがあります。（ジャーナルプラグインとしてcassandraを使用）。多くの場合、複数のアクターを同時に作成する必要があります。（たとえば、すべてのユーザにブロードキャストメッセージを送信する場合）と数千の永

4熱

1答えて

Spark Structured Streamingが背圧を処理する方法は？

私はSpark Structured Streamingでバックプレッシャ機能を分析しています。誰もが詳細を知っていますか？プロセス受信レコードをコードでチューニングすることは可能ですか？ありがとう

1熱

1答えて

観測可能な要素を正しい（実際の）時間にどのように渡すのですか？

これは、ロボットは、その後、原点(0,0)から始まり、その後、矩形の左コーナーを下げるために行く、その後、右下隅を意味し、いくつかのルート public static double[][] points = new double[][]{ {0, 0}, {0, 10}, {1, 10}, {1, 0}, {0, 0} };