akka-stream

1熱

1答えて

Akka：新しいHttpRequestsを作成するためのHttpResponseの将来のマップ

私の目的は、最終的なMap [id、Result]を作成することです。 case class Result(id: String, descr: String) 問題：私はJSONを返すAPIを打つしたいここでResultは、以下のようにケースクラスです。このJSONを解析し、JSON全体からすべてのmember_idフィールドを取得します。 1）： memberList : List[Strin

json scala akka akka-stream akka-http 2017-11-01

---

2熱

1答えて

ActorRefをSource.actorRef（）から取得するにはどうすればよいですか？

ウェブアプリケーションにいくつかのサーバーサイドイベント（SSE）を実行したいと思います。私はすべてのSSEの配管を行っていると思う。私は今、家のAkka HTTP側にSourceを作成する必要があります。 は、私はあなたがこのような何かを行うことができますが見つかりました： 私は何をしたいことは、おそらく役者にメッセージを送信することにより、このソースに「公開」何とかです val source

akka akka-stream 2017-11-02

---

0熱

1答えて

akkaストリームの接続kafkaとakka http

現在、akkaストリームで遊んでいて、次の例を試しました。 特定のHTTPエンドポイントを要求するときに、kafkaから最初の要素を取得します。 これは私が書いたコードとその動作です。 get { path("ticket"/IntNumber) { ticketNr => val future = Consumer.plainSource(consumerSetting

apache-kafka akka-stream akka-http 2017-11-04

---

1熱

1答えて

Play Framework WebSocketの例 - 実際のソースは1つだけです（偽のジェネレータはありません）

https://github.com/playframework/play-java-websocket-exampleという変更を加えて助けが必要です。 この例文は、指定された株式IDについてはSourceに基づいています。 public Source<StockUpdate, NotUsed> update() { return source.throttle(1, duration

java playframework websocket akka-stream playframework-2.6 2017-11-04

---

0熱

2答えて

akkaストリームのKeepは何を意味しますか？

私はアッカストリームを学習し、コード内でKeep.leftとKeep.rightが発生しています：ここ implicit val system = ActorSystem("KafkaProducer") implicit val materializer = ActorMaterializer() val source = Source(List("a", "b", "c")) val

scala akka-stream 2017-11-04

---

1熱

1答えて

汎用パラメータスカラのアクセスタイプパラメータ

Akkaストリームで次の関数のラッパーを作成しようとしています。 RestartFlow.withBackoff(minBackoff = 3.seconds, maxBackoff = 30.seconds, randomFactor = 0.2) { () => s } ここで、sはバックオフで折り返しているソースです。この RetryFlow(

scala generics akka-stream scala-generics 2017-11-06

---

0熱

1答えて

Akka HTTPがHTTP要求を完了するのにかかる時間の長さ

私は、ケースクラス（Event）をとり、それをHTTPエンドポイントに送り戻すフローを構築しました。それはそうのように実装されています：私は、HTTPリクエストにかかる時間を監視したい def handleResponse(endpoint: String)(responseTuple: (Try[HttpResponse], Event))(implicit actorSystem: Actor

scala akka akka-stream akka-http 2017-11-07

---

1熱

1答えて

Akka Streams - FlowShapeをジャンプする

私は以下のグラフを持っています。 inflateFlowステージでは、すでにDBで処理されているリクエストがあるかどうかを確認します。すでに処理されたメッセージがある場合は、MsgSuccessを返信し、RequestProcessは返信しませんが、次のFlowShapeは受け付けません。RequestProcessが必要です。どこでもEitherを追加することなくflowInflateからflo

scala akka-stream 2017-11-09

---

0熱

1答えて

Akka Streams KafkaでProducerMessageを構築する際にオフセットパラメータを設定する方法は？

私はScala 2.11とAkka Streams Kafka 0.17を使用しています。 私はストリームあります がSourceがSource.actorRefを使用して作成されます。ここでは、アクターは一定の間隔で実行され、連続してメッセージを生成し、ストリームに出力されます。 ProducerをFlowとして添付しました。プロデューサーはProducerMessage.Messageをカフカ

scala apache-kafka akka-stream reactive-kafka 2017-11-11

---