I’m having an issue with ContainerExtension, where...
# kotest
i
I’m having an issue with ContainerExtension, where if i do this
Copy code
val schemaRegistry =install(ContainerExtension(schemaRegistryContainer.apply { config(kafka) }, mode = ContainerLifecycleMode.Spec))

val schemaRegistry =install(ContainerExtension(schemaRegistryContainer.apply { config(kafka) }, mode = ContainerLifecycleMode.Spec))
Copy code
/**
    * Mounts the container, starting it if necessary. The [configure] block will be invoked
    * every time the container is mounted, and after the container has started.
    */
   override fun mount(configure: T.() -> Unit): T {
      if (!container.isRunning) {
         beforeStart()
         container.start()
         afterStart()
      }
      container.configure()
      return container
   }