API Reference Pulsar v#3.0.1

Copy Markdown View Source

Modules

An Apache Pulsar client for Elixir.

A client represents an isolated Pulsar connection context and owns the consumers and producers that use it.

A consumer subscribes to a topic and hands each message to a callback module.

Macro for creating Pulsar consumer callback modules that support internal state.

Represents a message received from a Pulsar topic.

A producer publishes messages to a topic.

A high-level interface for reading messages from Pulsar topics using Elixir's Stream API. The reader uses non-durable subscriptions, meaning it doesn't persist its position and starts fresh on each connection.

Internal callback module for Pulsar.Reader.

Schema definition for Pulsar messages.