Fix container

Author: nomisRev

guide/src/main/kotlin/KafkaContainer.kt

@@ -1,10 +1,6 @@
-import com.github.dockerjava.api.command.InspectContainerResponse
-import io.github.nomisRev.kafka.Admin
-import io.github.nomisRev.kafka.AdminSettings
-import io.github.nomisRev.kafka.await
-import kotlinx.coroutines.runBlocking
 import org.testcontainers.containers.KafkaContainer
 import org.testcontainers.utility.DockerImageName
+import java.lang.System.getProperty
 
 /**
  * A singleton `Kafka` Test Container.
@@ -30,17 +26,18 @@ import org.testcontainers.utility.DockerImageName
  * @see https://pawelpluta.com/optimise-testcontainers-for-better-tests-performance/
  */
 class Kafka private constructor(imageName: DockerImageName) : KafkaContainer(imageName) {
-
+  
   companion object {
+    private val image: DockerImageName =
+      if (getProperty("os.arch") == "aarch64") DockerImageName.parse("niciqy/cp-kafka-arm64:7.0.1")
+        .asCompatibleSubstituteFor("confluentinc/cp-kafka")
+      else DockerImageName.parse("confluentinc/cp-kafka:6.2.1")
+    
     val container: KafkaContainer by lazy {
-      Kafka(DockerImageName.parse("niciqy/cp-kafka-arm64:7.0.1").asCompatibleSubstituteFor("confluentinc/cp-kafka"))
-        .withReuse(true)
-        .withNetwork(null)
-        .withLabel("io.github.nomisrev.kafka", "fqn-testcontainers-reuse")
-        .also { it.start() }
+      Kafka(image).also { it.start() }
     }
   }
-
+  
   // override fun containerIsStarted(containerInfo: InspectContainerResponse?, reused: Boolean) {
   //   super.containerIsStarted(containerInfo, reused)
   //   // If we're reusing the container, we want to reset the state of the container. We do this by