Akka Cluster (and Cluster Client) on Kubernetes

[Ashley Aitken]

Howdy All,

Has anyone had any experience getting an Akka Cluster and Cluster Client running on Kubernetes, e.g. on Google Container Engine (GCE)?

I note the problem with Akka dropping messages when the host IP address doesn't match the container virtual IP address.

I note the solution in Akka 2.4.

I would most appreciate anyone confirming if they have an Akka Cluster running on Kubernetes (on GCE or not) and sharing any tips / hints.

Thanks in advance,

Ashley.

[Jim Hazen]

Might want to look at this thread.  https://groups.google.com/forum/#!topic/akka-user/wyA4xNfM5LM

[Jim Hazen]

Lol.  Or not, since you're the OP.  Oh well, need more coffee.

[Ashley Aitken]

Thanks Jim, lol and I would be happy to shout you that coffee for taking the time to reply.

[Mahmoud Atef]

Did it work with you, I mean Akka cluster over kubernetes?

[Ruben Wagner]

Hi,

actually the configuration is a bit tricky, because you need to set a fixed seed node, which is not fixed in Kubernetes. I looked at the Cassandra pod and ported it to Akka Cluster (s. attached file). It derives the config from the Kubernetes API and then starts the Akka Cluster. If the kubernetes service does not exist yet, it has to fail fast, so it can be restarted from the Kubernetes controller, that's why it throws an exception. As an entry point in the main class one can use something like this:

...

val kubeConfig = KubernetesSeednodeConfig.getConfig("akka-kube")

val config = kubeConfig.withFallback(ConfigFactory.load()).resolve()

val system = ActorSystem("akka-kube", config)

...

I will put this all together in a github project, when I find the time and post the link here. Also I did not have the time to play around with, it is not perfect and comes with no warranties.

Ruben

[Ashley Aitken]

Thanks for sharing Ruben.

I was considering if it could be done without a fixed seed node.

I am keen to see your github project when you have time.

--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to a topic in the Google Groups "Akka User List" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/obBNWy1bixI/unsubscribe.
To unsubscribe from this group and all its topics, send an email to akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

<KubernetesSeednodeConfig.scala>

[Ashley Aitken]

This looks very interesting:

https://github.com/vyshane/klusterd

Thanks to VYShane.

[Ruben Wagner]

Hi,

it took me some time, to find some time. But finally I created a github project from my solution:

https://github.com/ouven/akka-k8s-seednode

Ruben