KafkaContainerWrapper.groovy

class KafkaContainerWrapper extends KafkaContainer {

    private static KafkaContainerWrapper CONTAINER

    private KafkaContainerWrapper(String confluentPlatformVersion) {
        super(confluentPlatformVersion)
    }

    static KafkaContainer getContainer() {
        if (CONTAINER == null) {
            CONTAINER = new KafkaContainerWrapper("5.3.0")
                    .withReuse(true)
                    .withNetwork(null)
                    .withLabel("com.example.my.application.name", "testcontainersReuseSample")
            CONTAINER.start()
        }
        CONTAINER
    }
}