There was an error while loading. Please reload this page.
Currently the asynchronous producer only supports sending values, see
pulsar-client-python/pulsar/asyncio.py
Line 77 in 4629281
and the flush method and some other properties are not implemented, see #277 (comment), we need to determine whether to implement them
flush
The async Producer class is missing several methods that are available in the synchronous Producer class:
flush()
producer_name()
topic()
last_sequence_id()
is_connected()
Currently the asynchronous producer only supports sending values, see
pulsar-client-python/pulsar/asyncio.py
Line 77 in 4629281
and the
flushmethod and some other properties are not implemented, see #277 (comment), we need to determine whether to implement themThe async Producer class is missing several methods that are available in the synchronous Producer class:
flush()- to flush buffered messagesproducer_name()- to get the producer nametopic()- to get the topic namelast_sequence_id()- to get the last sequence IDWe should not add this API, see explanation here: feat: add producer connectivity functionality #286 (review)is_connected()- to check connection status