Skip to content

Support setting more methods for asynchronous producer #278

@BewareMyPower

Description

@BewareMyPower

Currently the asynchronous producer only supports sending values, see

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:

  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

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions