BewareMyPower opened a new pull request, #189: URL: https://github.com/apache/pulsar-client-python/pull/189
Master issue: https://github.com/apache/pulsar-client-python/issues/55 ### Modifications Introduce a `pulsar.asyncio` module that includes the asynchronous APIs to work with Python asyncio module. Example: ```python async def main(): client = Client('pulsar://localhost:6650') try: producer = await client.create_producer('topic') msg_id = await producer.send('msg'.encode()) await producer.close() except PulsarException as e: error = e.error() await client.close() ``` The creation of `Client` reuses the same keyword arguments from `pulsar.Client` but the options for creating producer and sending messages are not added yet. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
