manub / scalatest-embedded-kafka

A library that provides an in-memory Kafka instance to run your tests against.
MIT License
294 stars 87 forks source link

Kafka 1.1.0 #129

Closed NeQuissimus closed 6 years ago

NeQuissimus commented 6 years ago

Any chance you could release an artifact with dec812a1518c38cabb598b69064bf1125374d312 in it? :)

Thank you!

Edit: For future reference, I am seeing this error I suspect is caused by my pulling in Kafka 1.1.0 while scalatest-embedded-kafka expects 1.0.1:

[info]   java.lang.NoSuchMethodError: org.apache.kafka.common.network.ChannelBuilders.serverChannelBuilder(
[info]   Lorg/apache/kafka/common/network/ListenerName;Lorg/apache/kafka/common/security/auth/SecurityProto
[info]   col;Lorg/apache/kafka/common/config/AbstractConfig;Lorg/apache/kafka/common/security/authenticator
[info]   /CredentialCache;)Lorg/apache/kafka/common/network/ChannelBuilder;
[info]     kafka.network.Processor.<init>(SocketServer.scala:439)
[info]     kafka.network.SocketServer.newProcessor(SocketServer.scala:186)
[info]     kafka.network.SocketServer.$anonfun$startup$2(SocketServer.scala:96)
[info]     scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:156)
[info]     kafka.network.SocketServer.$anonfun$startup$1(SocketServer.scala:95)
[info]     kafka.network.SocketServer.$anonfun$startup$1$adapted(SocketServer.scala:90)
[info]     scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:59)
[info]     scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:52)
[info]     scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
[info]     kafka.network.SocketServer.startup(SocketServer.scala:90)
[info]     kafka.server.KafkaServer.startup(KafkaServer.scala:229)
[info]     net.manub.embeddedkafka.EmbeddedKafkaSupport.startKafka(EmbeddedKafka.scala:620)
[info]     net.manub.embeddedkafka.EmbeddedKafkaSupport.startKafka(EmbeddedKafka.scala:626)
[info]     net.manub.embeddedkafka.EmbeddedKafkaSupport.startKafka$(EmbeddedKafka.scala:624)
[info]     net.manub.embeddedkafka.EmbeddedKafka$.startKafka(EmbeddedKafka.scala:29)
[info]     net.manub.embeddedkafka.EmbeddedKafka$.start(EmbeddedKafka.scala:44)
francescopellegrini commented 6 years ago

I also would like a new release (or a RC) with ee9beb3 included, please.

manub commented 6 years ago

I'll be releasing a version during the weekend if not earlier. Thanks!

erikvanoosten commented 6 years ago

I am confused. What is the solution to this problem?

NeQuissimus commented 6 years ago

@erikvanoosten Use "net.manub" %% "scalatest-embedded-kafka" % "1.1.0-kafka1.1-nosr"