pulsar.asyncio.Client

class documentation

class Client: (source)

Constructor: Client(service_url, **kwargs)

View In Hierarchy

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)
async def close(self): (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:strThe topic name
Returns
ProducerThe producer created
Raises
PulsarException
_client: _pulsar.Client = (source)

Undocumented