由于 Akka Sharding,Lagom 微服务无法形成集群
Lagom microservice is not able to form cluster due to Akka Sharding
我有一个 Lagom 微服务,运行 在 Kubernetes 上有 3 个 PODs。启动时无法形成集群,并一直显示以下消息:
2019-07-12T19:29:27.310Z WARN akka.cluster.sharding.ShardRegion - Trying to register to coordinator at [ActorSelection[Anchor(akka.tcp://microservice@10.233.101.14:10001/), Path(/system/sharding/MicroserviceEventProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1580] buffered messages. [Coordinator [Member(address = akka.tcp://microservice@10.233.101.14:10001, status = Up)] is reachable.]
另外buffered messages
的人数也在不断增加。由于没有关于 Lagom 微服务这种行为的文档,谁能帮助我理解和解决这个问题?
我找不到这个问题的明确答案。但以下配置解决了问题:
sharding.state-store-mode = ddata
和
serialization-bindings {
"akka.Done" = akka-misc
"akka.actor.Address" = akka-misc
"akka.remote.UniqueAddress" = akka-misc
}
现在 Akka Cluster Shards 不再保存在 Event Store 中。
我有一个 Lagom 微服务,运行 在 Kubernetes 上有 3 个 PODs。启动时无法形成集群,并一直显示以下消息:
2019-07-12T19:29:27.310Z WARN akka.cluster.sharding.ShardRegion - Trying to register to coordinator at [ActorSelection[Anchor(akka.tcp://microservice@10.233.101.14:10001/), Path(/system/sharding/MicroserviceEventProcessorCoordinator/singleton/coordinator)]], but no acknowledgement. Total [1580] buffered messages. [Coordinator [Member(address = akka.tcp://microservice@10.233.101.14:10001, status = Up)] is reachable.]
另外buffered messages
的人数也在不断增加。由于没有关于 Lagom 微服务这种行为的文档,谁能帮助我理解和解决这个问题?
我找不到这个问题的明确答案。但以下配置解决了问题:
sharding.state-store-mode = ddata
和
serialization-bindings {
"akka.Done" = akka-misc
"akka.actor.Address" = akka-misc
"akka.remote.UniqueAddress" = akka-misc
}
现在 Akka Cluster Shards 不再保存在 Event Store 中。