Pulsar

Documentation

Official Modules

AtomicJar partners 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();

container, err := pulsar.RunContainer(ctx,
  testcontainers.WithImage("apachepulsar/pulsar:2.10.0"),
  pulsar.WithPulsarEnv("brokerDeduplicationEnabled", "true"),
  pulsar.WithFunctionsWorker(),
  pulsar.WithTransactions(),
)