KafkaContainerWrapper.groovy

class KafkaContainerWrapper extends KafkaContainer {

    private static KafkaContainerWrapper CONTAINER

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

    static KafkaContainer getContainer() {
        // container creation logic
        CONTAINER
    }

    @Override
    protected void containerIsStarted(InspectContainerResponse containerInfo, boolean reused) {
        if (!reused) {
            createKafkaTopics()
        }
    }

    void createKafkaTopics() {
        // invoking commands on container to create Apache Kafka topics
    }
}