Modules
Pulsar client for Elixir.
Unified Pulsar broker connection process.
A client represents an isolated Pulsar connection context.
Pulsar consumer process that communicates with broker processes.
Macro for creating Pulsar consumer callback modules that support internal state.
Manages chunked message assembly for Pulsar consumers.
A supervisor that manages a group of consumer processes for a single topic.
Represents a message received from a Pulsar topic.
A supervisor that manages individual consumer groups for partitioned topics.
A supervisor that manages individual producer groups for partitioned topics.
Pulsar producer process that communicates with broker processes.
Manages persistent storage of producer topic epochs across restarts.
A supervisor that manages a group of producer processes for a single 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.
This module handles topic lookup operations that discover which broker owns a particular topic. The lookup process may involve following redirects across multiple brokers in a cluster before finding the authoritative broker for a topic.