You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
Repository navigation
Support setting more methods for asynchronous producer #278
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