Move Kafka per class test to integration tests

akka · Mar 8, 2024 · 05d42f2 · 05d42f2
1 parent 6d4f856
commit 05d42f2
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/...afka/scaladsl/ConnectionCheckerSpec.scala → ...la/akka/kafka/ConnectionCheckerSpec.scala b/...afka/scaladsl/ConnectionCheckerSpec.scala → ...la/akka/kafka/ConnectionCheckerSpec.scala
@@ -3,9 +3,9 @@
  * Copyright (C) 2016 - 2023 Lightbend Inc. <https://www.lightbend.com>
  */
 
-package akka.kafka.scaladsl
+package akka.kafka
 
-import akka.kafka._
+import akka.kafka.scaladsl.{Consumer, SpecBase}
 import akka.kafka.testkit.KafkaTestkitTestcontainersSettings
 import akka.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike
 import akka.stream.scaladsl.{Keep, Sink}

diff --git a/...ka/kafka/scaladsl/MultiConsumerSpec.scala → .../scala/akka/kafka/MultiConsumerSpec.scala b/...ka/kafka/scaladsl/MultiConsumerSpec.scala → .../scala/akka/kafka/MultiConsumerSpec.scala
@@ -3,9 +3,10 @@
  * Copyright (C) 2016 - 2023 Lightbend Inc. <https://www.lightbend.com>
  */
 
-package akka.kafka.scaladsl
+package akka.kafka
 
 import akka.Done
+import akka.kafka.scaladsl.SpecBase
 import akka.kafka.testkit.KafkaTestkitTestcontainersSettings
 import akka.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike
 import akka.stream.testkit.scaladsl.StreamTestKit.assertAllStagesStopped

diff --git a/.../kafka/scaladsl/RetentionPeriodSpec.scala → ...cala/akka/kafka/RetentionPeriodSpec.scala b/.../kafka/scaladsl/RetentionPeriodSpec.scala → ...cala/akka/kafka/RetentionPeriodSpec.scala
@@ -3,21 +3,20 @@
  * Copyright (C) 2016 - 2023 Lightbend Inc. <https://www.lightbend.com>
  */
 
-package akka.kafka.scaladsl
-
-import java.util.concurrent.ConcurrentLinkedQueue
+package akka.kafka
 
 import akka.Done
-import akka.kafka._
+import akka.kafka.scaladsl.{Consumer, SpecBase}
 import akka.kafka.testkit.KafkaTestkitTestcontainersSettings
 import akka.kafka.testkit.scaladsl.TestcontainersKafkaPerClassLike
 import akka.stream.scaladsl.Keep
 import akka.stream.testkit.scaladsl.StreamTestKit.assertAllStagesStopped
 import akka.stream.testkit.scaladsl.TestSink
 
+import java.util.concurrent.ConcurrentLinkedQueue
+import scala.collection.JavaConverters._
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.collection.JavaConverters._
 
 class RetentionPeriodSpec extends SpecBase with TestcontainersKafkaPerClassLike {
   private final val confluentPlatformVersion = "5.0.0"