Currently the asynchronous producer only supports sending values, see https://github.com/apache/pulsar-client-python/blob/4629281c4e1ea9928c6f2442d0aae5de826037ad/pulsar/asyncio.py#L77 and the `flush` method and some other properties are not implemented, see https://github.com/apache/pulsar-client-python/pull/277#discussion_r2643288675, we need to determine whether to implement them The async Producer class is missing several methods that are available in the synchronous Producer class: 1. `flush()` - to flush buffered messages 2. `producer_name()` - to get the producer name 3. `topic()` - to get the topic name 4. `last_sequence_id()` - to get the last sequence ID 5. ~~`is_connected()` - to check connection status~~ We should not add this API, see explanation here: https://github.com/apache/pulsar-client-python/pull/286#pullrequestreview-3710057600
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