private static final String PULSAR = "pulsar://pulsar:6650";

new DockerComposeContainer(new File("docker-compose/consumer.docker-compose.yml"))
        .withEnv("PULSAR_NETWORK", pulsarNetworkName)
        .withEnv("PULSAR", PULSAR)
        .waitingFor("main-consumer_1", Wait.forLogMessage(".*Consumer started.*", 1))
        .start();