Ive에 이와 같이 수천 개의 파일이 있습니다. Mr|David|Smith|[email protected]
Mrs|Teri|Smith|[email protected]
...
나는 각 줄을 하류에 있지만 제한된 방식으로 방출하는 파일을 읽고 싶습니다. 1/sec. 흐름에서 조절 기능을 작동시키는 방법을 알 수 없습니다. flow1 (아래)은 1 초 후
akka-cluster에서 알 수 있듯이 프론트 엔드 노드는 요청을 수신하여이를 실행하기 위해 백엔드 노드 중 하나에 작업을 보냅니다. 디버깅 목적으로 어떤 백엔드 노드가 작업을 실행 하는지를 어떻게 알 수 있습니까? akka는 다른 백엔드에서 현재 작업이 실행되고 있는지 확인할 수있는 UI도 제공합니까?
카카의 원격 통신에 Akka 액터를 사용하고 있습니다. 내가 받는다는을 사용하여 컴파일 한 후 생성 된 jar 파일을 배포, 나는 다음과 같은 오류가 발생합니다 : Exception in thread "Thread-113" com.typesafe.config.ConfigException$Missing: No configuration setting found
나는 Akka.NET을 읽고 숙련 된 인물이며, 내가 개발할 매우 기본적인 온라인 멀티 플레이어 게임에 적합하다고 생각한다. 저는 Akka.NET 내의 Persistence 모듈에 특히 관심이있었습니다. 내가 할 수있는 일이라면 언제든지 내 전체 액터 시스템의 스냅 샷을 가져 와서 선택한 시점에 스냅 샷을 복원하는 것입니다 (본질적으로 게임 상태의 저장 /
내가 Akka를 (아마 Alpakka 및/또는 Lagom과 함께) 사용하는 응용 프로그램을 가지고 있다고 가정 해 봅시다. Red Hat JBoss 퓨즈와 같은 iPaaS를 계속 사용할 수 있습니까? 그렇다면 이점은 무엇입니까? 그렇지 않다면, iPaaS의 대안 인 배우 시스템의 일부라고 어떻게 부릅니까?
방금 AKKA를 배우기 시작했으며 Learning AKKA 책에서 샘플 프로그램을 작성했지만 프로그램이 실행되지 않으며 추가 디버깅을위한 유용한 정보가 생성되지 않습니다. 나는 살펴보고 SetRequest.java package com.akkademy.messages;
public class SetRequest {
private String
첫 번째 Akka 테스트를 작성하고 문서를 검토하려고합니다. 나는 그것의 첫 번째 example을 실행하고 다음과 같은 오류 얻고 있었다 : override def receive: Receive = {
case p: ProducerRecord[_,_] =>
sendChannel.send(p.value())
case _ => logger.err
Akka Streams를 사용하여 서버에 요청을 동시에 보내고 각 요청을 원본 컨텍스트 (이 예제에서는 Int)와 연결하려고합니다. 이것은 내가 특히 val createRequestFlow: Flow[(String, String), (HttpRequest, Int), _] = Flow.fromFunction[(String, String), (HttpRequ
설명 : docs에서 설명했듯이 akka는 다른 유형보다 먼저 일부 유형의 메시지를 처리하려는 경우에 도움이되는 우선 순위 사서함을 제공합니다. 폭풍 문서에서 유사한 기능을 찾지 못했습니다. 비슷한 지원이 apache-storm에서 사용 가능합니까? 아니면 비슷한 동작이 어떻게 이루어질 수 있습니까?