pulsar.asyncio.Client

class documentation

class Client: (source)

The asynchronous version of pulsar.Client.

Method	`__init__`	See `pulsar.Client.__init__`
Async Method	`close`	Close the client and all the associated producers and consumers
Async Method	`create_producer`	Create a new producer on a given topic
Instance Variable	`_client`	Undocumented

def __init__(self, service_url, **kwargs): (source) ¶

Close the client and all the associated producers and consumers

Raises
`PulsarException`

async def create_producer(self, topic: str) -> Producer: (source) ¶

Create a new producer on a given topic

Parameters
topic:`str`	The topic name

Returns
`Producer`	The producer created

Raises
`PulsarException`

Undocumented