KafkaContainerWrapper.groovy

class KafkaContainerWrapper extends KafkaContainer {

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

    void setupSpringProperties() {
        String address = kafkaContainerAddress()
        setupBrokerAddress(address)
    }

    private String kafkaContainerAddress() {
        CONTAINER.getBootstrapServers()
    }

    private void setupBrokerAddress(String address) {
        System.setProperty("spring.kafka.bootstrap-servers", address)
    }
}