pulsar.asyncio.Producer

class documentation

class Producer: (source)

The Pulsar message producer, used to publish messages on a topic.

Method	`__init__`	Create the producer. Users should not call this constructor directly. Instead, create the producer via `Client.create_producer`.
Async Method	`close`	Close the producer.
Async Method	`send`	Send a message asynchronously.
Instance Variable	`_producer`	Undocumented

def __init__(self, producer: _pulsar.Producer): (source) ¶

Create the producer. Users should not call this constructor directly. Instead, create the producer via Client.create_producer.

Parameters
producer:`_pulsar.Producer`	The underlying Producer object from the C extension.

Close the producer.

Raises
`PulsarException`

async def send(self, content: bytes) -> pulsar.MessageId: (source) ¶

Send a message asynchronously.

Parameters
content:`bytes`	The message payload

Returns
`pulsar.MessageId`	The message id that represents the persisted position of the message.

Raises
`PulsarException`

Undocumented