pulsar.asyncio

module documentation
(source)

The Pulsar Python client APIs that work with the asyncio module.

Class Client The asynchronous version of pulsar.Client.
Class Consumer The Pulsar message consumer, used to subscribe to messages from a topic.
Class Producer The Pulsar message producer, used to publish messages on a topic.
Exception PulsarException The exception that wraps the Pulsar error code
Function _set_future Undocumented
def _set_future(future: asyncio.Future, result: _pulsar.Result, value: Any): (source) ΒΆ

Undocumented