ProducerState

faststream.kafka.publisher.state.ProducerState

Bases: Protocol

producer instance-attribute

producer

closed abstractmethod property

closed

stop async

stop()

Source code in faststream/kafka/publisher/state.py

async def stop(self) -> None: ...

flush async

flush()

Source code in faststream/kafka/publisher/state.py

async def flush(self) -> None: ...