-
Notifications
You must be signed in to change notification settings - Fork 48
Open
Milestone
Description
Currently the asynchronous producer only supports sending values, see
pulsar-client-python/pulsar/asyncio.py
Line 77 in 4629281
| async def send(self, content: bytes) -> pulsar.MessageId: |
and the flush method and some other properties are not implemented, see #277 (comment), we need to determine whether to implement them
The 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 IDis_connected()- to check connection status
Metadata
Metadata
Assignees
Labels
No labels