akka-stream

0열

1답변

Akka HTTP 및 Akka 스트림 - 상위 레벨 경로가있는 흐름 사용 API

이 질문은 Akka Streams의 이전 버전 & Akka HTTP에 대해 질문되었습니다. akka-http: complete request with flow이 대답의 문제점은 각 요청에 대해 새로운 흐름을 실현하는 데 필요한 각 흐름에 대한 것입니다. 1 년 후 최신 버전에서 흐름을 DSL 경로와 통합하는 가장 좋은 방법은 무엇입니까? 다시 Flow[Ht

0열

1답변

스칼라 : 외부 병합 정렬을 작성하기위한 파일 읽기

외부 병합 정렬을 스칼라로 구현하고 싶습니다. 주 메모리 전체에 들어갈 수없는 거대한 파일을 정렬하는 데 사용됩니다. 자세한 내용은 여기에서 찾을 수 있습니다 : - How external merge sort algorithm works? 지금, 나는 파일의 청크를 읽을 필요가 정렬이 디스크에 기록하고 등 등 독서의 가장 관용적/기능성 방법을 무엇 /거대한

0열

1답변

Marc21 Akka-Stream 이진 디코더

레코드의 길이를 제공하는 필드와 관련하여 다음과 같은 스펙을 가진 Marc21 바이너리 데이터 레코드를 디코딩하려고합니다. A 컴퓨터 자체로 생성 된 5 자의 숫자는 전체 레코드의 길이와 같습니다 (자체 및 레코드 터미네이터 포함). 숫자 은 오른쪽 정렬되며 사용되지 않는 위치에는 0이 포함됩니다. 나는 그러나 난 그냥 그 필드의 크기를 지정하는 방법을 모

0열

1답변

TTL

내가 akka 스트림을 사용 SQS을 들으려고 를 사용 akka 스트림과 상태를 관리하고이 코드를 사용 Q 의에서 내가 메시지를 얻을하는 방법 : 나는 이미 댓글을 달았습니다 implicit val system = ActorSystem() implicit val mat = ActorMaterializer() implicit val ec = Executi

0열

1답변

MergeHub w/Flow.mapAsync() 사용 방법

MergeHub을 어떻게 사용하는지 혼란 스럽습니다. 나는 주어진 함수가 다른 흐름 그래프를 만든 다음 Sink.ignore() 그것을 실행하고 CompletionStageFlow.mapAsync()의 값으로이 기다릴 것을 반환 Flow.mapAsync()를 사용하는 흐름 그래프를 설계하고있다. 중첩 된 흐름은 MergeHub을 구체화하여 반환 된 Sink

1열

1답변

Akka 스트림에서 Kafka Zookeeper 끝점을 지정하는 방법 Kafka ConsumerSettings

나는 구름이있는 곳에서 실행되는 Kafka Broker를 가지고 있으며, 명령 줄 소비자 도구를 통해이를 소비하려고 할 때 메시지를 소비 할 수 있습니다. 그러나 내가 akka-stream kafka ConsumerSettings에 동일한 끝점을 넣을 때 작동하지 않습니다. 예 : - bin/kafka-console-consumer.sh - 사육자 호스트

1열

1답변

DTO를 Alpakka Cassandra에 저장하십시오.

안녕하세요 저는 datastax 드라이버를 사용하여 내 자신의 Cassandra 커넥터를 만듭니다. 하지만 메모리 누출 문제가 있으므로 Cassandra 커넥터가있는 Alpakka de lightbend와 같은 다른 솔루션을 고려하기 시작합니다. 하지만 가난한 문서를 확인한 후에는 CQLSH 쿼리와 함께 커넥터를 사용하고 있으므로 내 마음이 바뀌었고 제 경

0열

1답변

statefulMapConcat을 사용하여 소스 반환

akka-http websocket 응용 프로그램에서 주어진 메시지를 다시 에코하는 경로가 있으며 응용 프로그램에서 상태를 유지해야합니다. 그래서 다음과 같이 잘 작동합니다 : override protected def routes: Route = pathSuffix("echo") { handleWebSocketMessages(echoMe

1열

1답변

메시지가 Akka Streams Flow 또는 Sink에 도착하는 속도를 측정하십시오.

저는 Akka Streams 애플리케이션을 작성했으며 정상적으로 작동합니다. 내가하고 싶은 일은 Akka Streams 애플리케이션을 실행하는 JVM intance에 JMX 콘솔을 연결하고 내 싱크 및 플로우로 들어오는 메시지의 양을 조사하는 것입니다. 이것이 가능합니까? 나는 봤지만 구체적인 방법을 찾지 못했습니다. 내 응용 프로그램의 마지막 단계는 카산

0열

1답변

Akka 스트림은 내가 데이터 <pre><code>A A A B B C C C C ... (very long) </code></pre> <p></p>의 정렬 된 스트림이 작은 스트림

에 감소 그리고 난 형태로 집계 스트림으로 변환 할 : (A, 3) (B, 2) (C, 4) Akka Streams에서 어떤 연산자를 사용할 수 있습니까? Source.fromPublisher(publisher) .aggregateSomehow() // ? .runWith(sink) 나는 .groupBy으로 검토 한하지만 내가하지