Ido Flax
11/07/2024, 5:55 PMval schemaRegistry =install(ContainerExtension(schemaRegistryContainer.apply { config(kafka) }, mode = ContainerLifecycleMode.Spec))
val schemaRegistry =install(ContainerExtension(schemaRegistryContainer.apply { config(kafka) }, mode = ContainerLifecycleMode.Spec))
/**
* 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
}