akka-cluster

0열

1답변

Flink TaskManager가 docker swarm 작업에서 JobManager에 연결할 수 없습니다.

TaskManager가 docker swarm 스택의 JobManager와 통신하도록 관리 할 수 없습니다. 내가 docker stack deploy에 사용하는 stack.yml 파일의 내용은 다음과 같습니다 version: "3" services: jobmanager: image: affo/flink:1.1.3 ports:

5열

1답변

Akka 클러스터에서 구독자의 수신 방법을 테스트하려면 어떻게해야합니까?

나는 다음과 같은 Subscriber 추상 기본 클래스가 있습니다 abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging { import DistributedPubSubMediator.{ Subscribe, SubscribeAck } val mediat

1열

2답변

AKKA- 이름이 클러스터에서 uniqe가 아닌 경우 액터 작성을 차단하는 방법

시스템에서 동일한 이름을 공유하는 액터가있을 가능성을 차단하려고합니다 (서로 다른 경로에 있으므로 InvalidActorNameException).) 발생되지 않습니다 application.conf : someactor { akka.remote.netty.tcp.port = 6405 akka.cluster.auto-down-unreacha

0열

1답변

Akka - router supervisorStrategy- 이벤트시 라우터에 메시지를 보내는 방법

안녕하세요 저는 라우터 전략을 구현하고 싶습니다. 일부 이벤트에서 라우터에 메시지를 보내지 만 라우터에 대한 참조를 얻는 방법을 모르겠습니다. 전략 구현 내부. 이 내가 할 노력하고있어입니다 : 자기 라우터 ActorRef해야하지만, 자기가이 맥락에서 인식되지 않는 val router = system.actorOf(RoundRobinPool(5, super

3열

1답변

Akka 클러스터에서 Akka-HTTP 서버를 실행하는 방법은 무엇입니까?

Akka 클러스터를 구축 중이며 Akka-HTTP 서버를 내부 API 서버로 사용하려고합니다. 어떻게 그 일을합니까? 나는 그것이 클러스터에 대한 액세스 포인트이기 때문에 그것이 클러스터 싱글 톤이 될 것이라고 상상할 것이다.하지만 배우를 만드는 것은 이상하게 보일 것이다. 아무것도하지 않을 receive() 메소드가 필요하다. 추측).

4열

1답변

Kubernetes - Akka 클러스터링 배포

kubernetes를 사용하는 배포 용 도커 이미지와 해당 yaml 파일이 있습니다. 우리가 만든 응용 프로그램은 akka-http와 함께 scala에 있습니다. 우리는 akka 클러스터를 사용했습니다. pod ip를 사용하는 응용 프로그램 코드에서 사용되는 구성 파일에 특정 변수 (이 경우에는 시드 노드 - akka 클러스터)가 있습니다. 그러나 배치가

2열

1답변

akka 클러스터 인식 라우터 및 akka 클러스터 샤딩의 사용 사례가 다릅니 까?

클러스터 인식 라우터 : 여기 val router = system.actorOf(ClusterRouterPool( RoundRobinPool(0), ClusterRouterPoolSettings( totalInstances = 20, maxInstancesPerNode = 1, allowLocalRoutees = f

2열

1답변

Akka 클러스터 : 회원이 도달 할 수 없다고 표시되면 UnreachableMember 이벤트가 수신되지 않는 이유는 무엇입니까?

다른 노드에 도달 할 수없는 경우 클러스터 노드의 동작을 변경하고 싶습니다. 그래서 다른 회원이 도달 할 수 없을 때 알려주고 싶습니다. 회원이 도달 할 수없는 경우 , 내가 로그에서 볼 수 있습니다 [warn] a.c.ClusterCoreDaemon - Cluster Node [akka.tcp://[email protected]:2554] - Markin

5열

2답변

Akka 단일 실패 지점

단일 실패 지점이없는 시스템을 만들고 싶습니다. 나는 라우터가 그 일을하는 도구라고 생각했지만 예상대로 작동하는지 확신 할 수 없었다. 이 내 프로그램의 진입 점입니다 : object Main extends App{ val system = ActorSystem("mySys", ConfigFactory.load("application"))

1열

1답변

Akka 클러스터 : Reachable 이벤트가 발생하지 않는 이유는 무엇입니까?

저는 Akka 클러스터에 두 개의 노드가 있습니다. 두 노드 중 하나가 다운되면 cluster.subscribe( self, InitialStateAsEvents, classOf[ClusterDomainEvent]) , 나는이 Unreachable 이벤트를 수신하고 나는 일부 로그 다음과 같은 나에게 경고를 몇 초마다 수신을 시