import org.testcontainers.containers.DockerComposeContainer

final int PULSAR_ADMIN_PORT = 8080;
final int PULSAR_DATA_PORT = 6650;

new DockerComposeContainer("pulsar", new File("docker-compose/pulsar.docker-compose.yml"))
        .withExposedService("pulsar_1", PULSAR_ADMIN_PORT,
                            Wait.forHttp("/metrics").forStatusCode(200).forPort(PULSAR_ADMIN_PORT))
        .withExposedService("pulsar_1", PULSAR_DATA_PORT, Wait.forListeningPort())
        .start();