KafkaContainerWrapper.groovy

class KafkaContainerWrapper extends KafkaContainer {

    private static KafkaContainerWrapper CONTAINER
    private KafkaContainerWrapper(String confluentPlatformVersion) {...}

    static KafkaContainer getContainer() {
        if (CONTAINER == null) {
            CONTAINER = new KafkaContainerWrapper("5.3.0")
            CONTAINER.start()
            CONTAINER.setupSpringProperties()
        }
        CONTAINER
    }

    void setupSpringProperties() {...}
    private String kafkaContainerAddress() {...}
    private void setupBrokerAddress(String address) {...}
}