ProducerState faststream.kafka.publisher.state.ProducerState # Bases: Protocol producer instance-attribute # producer: AIOKafkaProducer closed abstractmethod property # closed: bool stop async # stop() -> None Source code in faststream/kafka/publisher/state.py 19async def stop(self) -> None: ... flush async # flush() -> None Source code in faststream/kafka/publisher/state.py 21async def flush(self) -> None: ...