README.adoc

embedded-pulsar

Maven dependency

pom.xml

<dependency>
    <groupId>com.playtika.testcontainers</groupId>
    <artifactId>embedded-pulsar</artifactId>
    <scope>test</scope>
</dependency>

Consumes (via bootstrap.properties)

• embedded.pulsar.enabled (true|false, default is true)

• embedded.pulsar.docker-image (default is 'apachepulsar/pulsar:4.1.2')

  • Image versions on dockerhub

• embedded.toxiproxy.proxies.pulsar.enabled Enables both creation of the container with ToxiProxy TCP proxy and a proxy to the embedded-pulsar container.

Produces

• embedded.pulsar.brokerUrl

• embedded.pulsar.httpServiceUrl

• embedded.pulsar.toxiproxy.host

• embedded.pulsar.toxiproxy.port

• embedded.pulsar.networkAlias

• embedded.pulsar.internalBrokerPort

• Bean ToxiproxyContainer.ContainerProxy pulsarContainerProxy

Example

PulsarClient pulsarClient = PulsarClient.builder()
        .serviceUrl(environment.getProperty("embedded.pulsar.brokerUrl"))
        .build();