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)
            CONTAINER.start()
        }
        CONTAINER
    }

}