Remove the coupling with ScalaTest (#146)

Author: crankydillo

build.sbt

@@ -21,8 +21,8 @@ lazy val commonSettings = Seq(
 
 lazy val commonLibrarySettings = libraryDependencies ++= Seq(
   "org.apache.avro" % "avro" % "1.8.1",
-  "org.scalatest" %% "scalatest" % "3.0.5",
   "org.apache.kafka" %% "kafka" % kafkaVersion,
+  "org.scalatest" %% "scalatest" % "3.0.5" % Test,
   "com.typesafe.akka" %% "akka-actor" % akkaVersion % Test,
   "com.typesafe.akka" %% "akka-testkit" % akkaVersion % Test
 )

embedded-kafka/src/main/scala/net/manub/embeddedkafka/EmbeddedKafka.scala

@@ -24,7 +24,6 @@ import org.apache.kafka.common.serialization.{
 }
 import org.apache.kafka.common.{KafkaException, TopicPartition}
 import org.apache.zookeeper.server.{ServerCnxnFactory, ZooKeeperServer}
-import org.scalatest.Suite
 
 import scala.collection.JavaConverters._
 import scala.collection.mutable.ListBuffer
@@ -34,7 +33,6 @@ import scala.reflect.io.Directory
 import scala.util.Try
 
 trait EmbeddedKafka extends EmbeddedKafkaSupport[EmbeddedKafkaConfig] {
-  this: Suite =>
 
   override def baseConsumerConfig(
       implicit config: EmbeddedKafkaConfig): Map[String, Object] =

kafka-streams/src/main/scala/net/manub/embeddedkafka/streams/EmbeddedKafkaStreams.scala

@@ -2,14 +2,12 @@ package net.manub.embeddedkafka.streams
 
 import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig, UUIDs}
 import org.apache.kafka.streams.{KafkaStreams, Topology}
-import org.scalatest.Suite
 
 /** Helper trait for testing Kafka Streams.
   * It creates an embedded Kafka Instance for each test case.
   * Use `runStreams` to execute your streams.
   */
 trait EmbeddedKafkaStreams extends EmbeddedKafka with TestStreamsConfig {
-  this: Suite =>
 
   /** Execute Kafka streams and pass a block of code that can
     * operate while the streams are active.

kafka-streams/src/main/scala/net/manub/embeddedkafka/streams/EmbeddedKafkaStreamsAllInOne.scala

@@ -3,7 +3,6 @@ package net.manub.embeddedkafka.streams
 import net.manub.embeddedkafka.{Consumers, EmbeddedKafkaConfig}
 import org.apache.kafka.clients.consumer.KafkaConsumer
 import org.apache.kafka.streams.Topology
-import org.scalatest.Suite
 
 /** Convenience trait for testing Kafka Streams with ScalaTest.
   * It exposes `EmbeddedKafkaStreams.runStreams` as well as `Consumers` api
@@ -13,7 +12,6 @@ import org.scalatest.Suite
   * @see [[EmbeddedKafkaStreams]]
   */
 trait EmbeddedKafkaStreamsAllInOne extends EmbeddedKafkaStreams with Consumers {
-  this: Suite =>
 
   /** Run Kafka Streams while offering a String-based consumer for easy testing of stream output.
     *

schema-registry/src/main/scala/net.manub.embeddedkafka/schemaregistry/streams/EmbeddedKafkaStreamsWithSchemaRegistry.scala

@@ -8,7 +8,6 @@ import net.manub.embeddedkafka.schemaregistry.{
 }
 import net.manub.embeddedkafka.streams.TestStreamsConfig
 import org.apache.kafka.streams.{KafkaStreams, Topology}
-import org.scalatest.Suite
 
 // TODO: need to find a better way of not duplicating this code from the kafka-streams module
 
@@ -19,7 +18,6 @@ import org.scalatest.Suite
 trait EmbeddedKafkaStreamsWithSchemaRegistry
     extends EmbeddedKafkaWithSchemaRegistry
     with TestStreamsConfig {
-  this: Suite =>
 
   /** Execute Kafka streams and pass a block of code that can
     * operate while the streams are active.

schema-registry/src/main/scala/net.manub.embeddedkafka/schemaregistry/streams/EmbeddedKafkaStreamsWithSchemaRegistryAllInOne.scala

@@ -4,7 +4,6 @@ import net.manub.embeddedkafka.Consumers
 import net.manub.embeddedkafka.schemaregistry.EmbeddedKafkaConfigWithSchemaRegistry
 import org.apache.kafka.clients.consumer.KafkaConsumer
 import org.apache.kafka.streams.Topology
-import org.scalatest.Suite
 
 // TODO: need to find a better way of not duplicating this code from the kafka-streams module
 
@@ -18,7 +17,6 @@ import org.scalatest.Suite
 trait EmbeddedKafkaStreamsWithSchemaRegistryAllInOne
     extends EmbeddedKafkaStreamsWithSchemaRegistry
     with Consumers {
-  this: Suite =>
 
   /** Run Kafka Streams while offering a String-based consumer for easy testing of stream output.
     *