LoginType was in 0.10.x release. This seems to indicate Kafka version mismatch.
Can you check the dependencies of your test ? Thanks On Tue, Feb 13, 2018 at 8:03 PM, Ian Ewing <[email protected]> wrote: > I have been trying to figure out how to unit test a kafka producer. Should > take in a simple integer and perform some addition. Followed what I could > find on spring kafka unit testing but keep running into this error: > > 19:53:12.788 [main] ERROR kafka.server.KafkaServer - [Kafka Server 0], > Fatal error during KafkaServer startup. Prepare to shutdown > java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType > at kafka.network.Processor.<init>(SocketServer.scala:406) > at kafka.network.SocketServer.newProcessor(SocketServer.scala:141) > at > kafka.network.SocketServer$$anonfun$startup$1$$anonfun$ > apply$1.apply$mcVI$sp(SocketServer.scala:94) > at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:160) > at > kafka.network.SocketServer$$anonfun$startup$1.apply(SocketServer.scala:93) > at > kafka.network.SocketServer$$anonfun$startup$1.apply(SocketServer.scala:89) > at scala.collection.Iterator$class.foreach(Iterator.scala:893) > at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) > at scala.collection.MapLike$DefaultValuesIterable.foreach( > MapLike.scala:206) > at kafka.network.SocketServer.startup(SocketServer.scala:89) > at kafka.server.KafkaServer.startup(KafkaServer.scala:219) > at kafka.utils.TestUtils$.createServer(TestUtils.scala:120) > at kafka.utils.TestUtils.createServer(TestUtils.scala) > at > org.springframework.kafka.test.rule.KafkaEmbedded. > before(KafkaEmbedded.java:154) > at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46) > at org.junit.rules.RunRules.evaluate(RunRules.java:20) > at org.junit.runners.ParentRunner.run(ParentRunner.java:363) > at > org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run( > SpringJUnit4ClassRunner.java:191) > at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > at > com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs( > JUnit4IdeaTestRunner.java:68) > at > com.intellij.rt.execution.junit.IdeaTestRunner$Repeater. > startRunnerWithArgs(IdeaTestRunner.java:51) > at > com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart( > JUnitStarter.java:242) > at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) > Caused by: java.lang.ClassNotFoundException: > org.apache.kafka.common.network.LoginType > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > ... 23 common frames omitted > > > Has anyone come across this situation? Any ideas on the direction a > solution would take? I can provide more information, code, etc. Whatever > extra is needed. Don't want to bog down the email with too much. > > Thanks > Ian >
