akka-stream

0열

1답변

내가 포트 그것은 완벽하게 작동하고 다음과 같은 메시지가 나타납니다 8080에서 로컬로 실행하는 간단한 Akka HTTP 서버를 가지고 고정 표시기 컨테이너에 조기 종료 파일. 그것을 docker run {my namespace}/my-app 을 지금 : FROM openjdk:8u131 ADD target/scala-2.12/my-app-assemb

0열

1답변

스파크 스트리밍이있는 akka 스트림 : 메시지가 배우에게 전달되지 않습니다. 죽은 편지 받기

나는 akka 스트리밍을 처음 듣습니다. 아래 예제를 github에서 실행하고 있습니다. 그러나 "Helloer"배우에게 보내는 메시지는 출력 콘솔에서 수신 및 표시되지 않습니다. StreamingApp.scala import _root_.akka.actor.{ Actor, Props } import org.apache.spark._ import org

0열

1답변

스트림 내에서 상태 유지

나는 사용자 데이터의 부하가 큽니다. 이 ID로 새 사용자인지 확인하고 싶습니다. db에 대한 호출을 줄이기 위해 이전 사용자를 기억하기 위해 상태를 유지합니다. val users = mutable.set[String]() //init the state from db user = db.getAllUsersIds() val source: Source[U

2열

1답변

Akka Streams Kafka - 소비자 용 단위 테스트

카프카 서버를 설정하고 프로듀서를 사용하여 메시지를 보내 로컬로 코드를 테스트하려고 시도했지만이 경우 단위 테스트를 작성할 수있는 방법이 있는지 궁금합니다. 코드 조각 (소비자가받은 메시지가 올바른지 테스트). val consumerSettings = ConsumerSettings(system, new ByteArrayDeserializer, ne

0열

1답변

Akka Streams : 파일 소스 제한

0열

1답변

akka HTTP에서 엑셀 파일을 업로드하는 방법 마이크로 서비스

는 엑셀 시트를 업로드하고 로컬에 저장하기위한 서버 측에서 def uploadFile(fileData: Multipart.FormData) = { println(" uploadFile ") // path("user"/"upload"/"file") { /* (post & entity(as[Multipart.FormData])) { fileData =>*

0열

1답변

akka 스트림의 미래 변화하기

Akka Streams를 사용하여 서버에 요청을 동시에 보내고 각 요청을 원본 컨텍스트 (이 예제에서는 Int)와 연결하려고합니다. 이것은 내가 특히 val createRequestFlow: Flow[(String, String), (HttpRequest, Int), _] = Flow.fromFunction[(String, String), (HttpRequ

4열

1답변

Akka 스트림 - 실패 후 브로드 캐스트 및 지퍼가있는 그래프 다시 시작

브로드 캐스트 및 지퍼가있는 흐름 그래프가 있습니다. 무언가 (그것이 무엇이든 상관없이)가이 흐름에서 실패하면, 문제가되는 요소를 전달하고 다시 시작하고 싶습니다. (1,1) (2,2) (3,3) (4,4) 우리는 어떤 일을했습니다에만 인쇄, 그것은 교착, (1,1) (2,2) (3,3) (4,4) (5,5) (6,6) (7,7) (8

0열

2답변

실행 가능한 그래프를 중지하는 방법

akka 스트림으로 내 첫 번째 단계를 얻으십시오. 내가 g.run() 하지만 난 그게 어떻게 중지 할 수 있습니다를 사용하여 그래프를 실행할 수 있습니다 val topHeadSink = Sink.head[Int] val bottomHeadSink = Sink.head[Int] val sharedDoubler = Flow[Int].map(_ * 2)

1열

1답변

Akka : 새로운 HttpRequests를 만들기위한 HttpResponse의 미래

내 목표는 최종 Map [id, Result]를 만드는 것입니다. case class Result(id: String, descr: String) 문제 : 다음 Result은 다음과 같은 경우 클래스는 내가 JSON을 반환하는 API를 치고 싶다. 이 JSON을 구문 분석하고 전체 JSON에서 모든 member_id 필드를 검색 할 것입니다. 1) : me