🚨 AtomicJar is now part of Docker 🐋! Read the blog

Documentation

Java Go

Official Module

StreamNative
We partner with software vendors to maintain and certify official modules.

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(),
)