Description
Apache Pulsar is an open-source, distributed messaging and streaming platform. Messages can be consumed and acknowledged individually or consumed as streams with less than 5ms of latency.Examples
var pulsar = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.10.0"));
pulsar.start();
pulsarContainer, err := pulsar.RunContainer(ctx,
testcontainers.WithImage("apachepulsar/pulsar:2.10.0"),
pulsar.WithPulsarEnv("brokerDeduplicationEnabled", "true"),
pulsar.WithFunctionsWorker(),
pulsar.WithTransactions(),
)