Not sure if this is the right answer, but this seems to fix the problem for
now.
a.dependsOn(kafka)
b.dependsOn(kafka)
c.dependsOn(kafka)
lazy val coreTests = Project(id = "core-tests", base = file(
"./modules/core/tests"))
.settings(
projectDependencies := {
val kafkaRule = ExclusionRule("com.typesafe.akka",
"akka-stream-kafka")
Seq(
(projectID in a).value.excludeAll(kafkaRule),
(projectID in b).value.excludeAll(kafkaRule),
(projectID in c).value.excludeAll(kafkaRule),
)
},
Settings.levelDb, Settings.test)
.dependsOn(a % "test", b % "test", c % "test")
On Saturday, August 20, 2016 at 3:43:30 PM UTC+8, drewhk wrote:
>
> This looks like a typical classpath issue. I think you have incompatible
> versions of some libraries in your classpath.
>
> -Endre
>
> On Sat, Aug 20, 2016 at 9:30 AM, Lap Ming Lee <[email protected]
> <javascript:>> wrote:
>
>> I keep on getting this error when I restart my IntelliJ to run unit test
>> on my reactive streams:
>>
>> Uncaught error from thread [KafkaAvroSpec-akka.kafka.default-dispatcher-5
>> ] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for
>> ActorSystem[KafkaAvroSpec]
>> java.lang.NoSuchMethodError: akka.kafka.internal.SingleSourceLogic.
>> getStageActor(Lscala/Function1;)Lakka/stream/stage/
>> GraphStageLogic$StageActor;
>> at akka.kafka.internal.SingleSourceLogic.preStart(SingleSourceLogic.
>> scala:52)
>> at akka.stream.impl.fusing.GraphInterpreter.init(GraphInterpreter.scala:
>> 468)
>> at akka.stream.impl.fusing.GraphInterpreterShell.init(
>> ActorGraphInterpreter.scala:365)
>> at akka.stream.impl.fusing.ActorGraphInterpreter.tryInit(
>> ActorGraphInterpreter.scala:504)
>> at akka.stream.impl.fusing.ActorGraphInterpreter.preStart(
>> ActorGraphInterpreter.scala:541)
>> at akka.actor.Actor$class.aroundPreStart(Actor.scala:489)
>> at akka.stream.impl.fusing.ActorGraphInterpreter.aroundPreStart(
>> ActorGraphInterpreter.scala:495)
>> at akka.actor.ActorCell.create(ActorCell.scala:590)
>> at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:461)
>> at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
>> at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
>> at akka.dispatch.Mailbox.run(Mailbox.scala:223)
>> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
>> java:1142)
>> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
>> .java:617)
>> at java.lang.Thread.run(Thread.java:745)
>>
>> After meddling with the Build.sbt, it would then work, but once I restart
>> it would failed again. Its draining quite a bit of time trying to unit
>> test right now. Does anyone know what may be the cause of this?
>>
>> So far the only way I have found is to remove the reactive-kafka
>> dependency, save, and then add it back again. But this isn't consistent.
>>
>> --
>> >>>>>>>>>> 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 the Google Groups
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an
>> email to [email protected] <javascript:>.
>> To post to this group, send email to [email protected]
>> <javascript:>.
>> Visit this group at https://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
--
>>>>>>>>>> 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 the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
