akka-stream

    0

    1답변

    내가 akka 스트림을 사용하여 SQS를들을려고하고이 코드를 사용 Q 있어에서 내가 메시지를 얻을 : (다음을 ACK) 물론 이 코드는 메시지를 하나씩 얻을를 : implicit val system = ActorSystem() implicit val mat = ActorMaterializer() implicit val ec = ExecutionConte

    0

    1답변

    웹 서비스 요청이 응답 할 때까지 10 초마다 10 초마다 웹 서비스 요청을 어떻게 재생합니까? 나는 RecoverWithRetries 및 InitialDelay을 시도했지만, 첫 번째 복구 즉시 웹 서비스 호출을 재생합니다 : FromThirdOfContract().RecoverWithRetries(e => { return Source.From

    1

    1답변

    나는 Akka 스트림을 배우기 시작했습니다. 이 제품의 매우 큰 성가심 중 하나는 거의 모든 클래스가 javadsl 및 scaladsl 네임 스페이스에 모두 나타납니다. 어쨌든 IntelliJ는 자동으로 javadsl 네임 스페이스에서 클래스를 자동으로 가져옵니다. 이로 인해 구문 오류가 발생하고 많은 시간을 낭비하게됩니다. scaladsl 네임 스페이스에

    0

    1답변

    나는이 응용 프로그램이 정확히 화면에 10 개의 행을 인쇄 예상 실행되는 Alpakka 카산드라 도서관 package com.abhi import akka.actor.ActorSystem import akka.stream.{ActorMaterializer, ClosedShape} import akka.stream.alpakka.cassandra.sc

    2

    1답변

    Scala 2.11.8에서 Slick 3.1.0을 사용하고 있습니다. 이것은 매끄러운 확장을 사용하여 Oracle 데이터베이스를 쿼리합니다. 나는 그것의 전체 결과를 읽는 것을 의미하는 것 같다 아무것도 인쇄하지 않고이 코드를 실행하면 type MyTup = (String, String, String) implicit val actorSystem = Ac

    0

    1답변

    카프카에 쓰기를 병렬 처리하고 싶습니다. 카프카에 데이터를 보내는 여러 제작자가 있습니다. 다른 내 스트림에는 소스의 여러 초기 단계가 있고 데이터를 전송할 때 16 명의 직원이 동시에 데이터를 보내고 싶습니다. Akka Streams Kafka를 akka-stream Graph DSL에 임베딩해야하고 밸런서를 사용하거나 더 쉬운 솔루션이 필요한지 궁금합니

    0

    1답변

    자바에서 사용자 지정 소스를 작성하는 실험을 해보았습니다. 특히 BlockingQueue에서 요소를 취하는 Source를 작성했습니다. 나는 Source.queue를 알고 있지만 Merge 단계에 이들 중 몇 개를 연결하면 구체화 된 값을 얻는 방법을 모르겠습니다. 어쨌든, 여기에 구현의 :이 public class TestingSource extends

    0

    1답변

    저는 AKKA를 처음 사용합니다 (자바를 사용하고 있습니다). Zip 파일을 원격 액터로 전송하는 방법을 알 수 없습니다. akka-http를 사용해야합니까? akka-streams을 시도했지만 원격 액터로 이진 파일을 전송하는 방법을 이해할 수 없었습니다.

    0

    1답변

    나는 그것은 매우 쉽게 소스와 싱크 카산드라를 사용할 수있게 Alpakka 카산드라 here 의 문서를 읽고있다. 그러나 흐름 사용은 어떻습니까? 흐름을 사용하여 나는 카산드라를 소스 또는 싱크대로 사용하지 않는다는 것을 의미합니다. 그러나 데이터 조회. 은 Alpakka를 사용하여 가능합니까? 또는 직접 Cassandra jdbc 코드를 작성해야합니까?

    0

    1답변

    val enableJdbcStreaming: (java.sql.Statement) => Unit = { statement ⇒ if (statement.isWrapperFor(classOf[com.mysql.jdbc.StatementImpl])) { statement.unwrap(classOf[com.mysql.jdbc.StatementI