mbuccini
commented
6 years ago While debugging to eventually create #162, I found out that the issue is different from what it seems.
it has a bunch of "recoverWith". In particular:
private lazy val _simpleImpl = {
val config = system.settings.config
val dynamic = system.dynamicAccess
def classNameFromConfig(path: String): String =
if (config.hasPath(path)) config.getString(path)
else "<nope>"
def create(clazzName: String) =
dynamic
.createInstanceFor[SimpleServiceDiscovery](clazzName, (classOf[ExtendedActorSystem] → system) :: Nil)
.recoverWith {
case _ ⇒
dynamic.createInstanceFor[SimpleServiceDiscovery](clazzName, (classOf[ActorSystem] → system) :: Nil)
}
.recoverWith {
case _ ⇒
dynamic.createInstanceFor[SimpleServiceDiscovery](clazzName, Nil)
}
// format: OFF
val i = create {
classNameFromConfig("akka.discovery." + _simpleImplMethod + ".class")
}.recoverWith {
case _ ⇒ create(classNameFromConfig(_simpleImplMethod + ".class"))
}.recoverWith {
case _ ⇒ create(_simpleImplMethod) // so perhaps, it is a classname?
}
// format: ON
i.getOrElse(
throw new IllegalArgumentException(
s"Illegal `akka.discovery.method` value '${_simpleImplMethod}' or incompatible class! " +
"The implementation class MUST extend akka.discovery.SimpleServiceDiscovery and take an " +
"ExtendedActorSystem as constructor argument.", i.failed.get)
)
}The first create call will try to initialize the correct akka.discovery.kubernetes.KubernetesApiSimpleServiceDiscovery.class class. However, it may fail for some reasons, like you are not running on kubernetes and therefore the file api-ca-path = "/var/run/secrets/kubernetes.io/serviceaccount/ca.crt" doesn't exist (at least that was the issue I found in my experiment).
Once it blows up, it goes to next "recoverWith", etc. The final recoverWith will try to instantiate "_simpleImplMethod" which is "kubernetes-api" that is not a java class.
I would suggest you to debug to find out what the underlying issue is. Set the breakpoint in one of those recoverWith to see why akka cannot instantiate the class (maybe you missed some configuration?).
I agree that the exception should give you a more meaningful message, though. Maybe having some logging would not be bad.
lmlynik
charlesa101
ktoso
castorm
isatimur
teroxik
chbatey
BassirouRabo
This is what I getting when setting up akka boostrapping with k8s discovery.
and dependencies