Skip to content

ProducerState

faststream.confluent.publisher.state.ProducerState #

Bases: Protocol

producer property #

producer: AsyncConfluentProducer

ping async #

ping(timeout: float) -> bool
Source code in faststream/confluent/publisher/state.py 
17
async def ping(self, timeout: float) -> bool: ...

stop async #

stop() -> None
Source code in faststream/confluent/publisher/state.py 
19
async def stop(self) -> None: ...

flush async #

flush() -> None
Source code in faststream/confluent/publisher/state.py 
21
async def flush(self) -> None: ...