Skip to content

EmptyProducerState

faststream.kafka.publisher.state.EmptyProducerState #

Bases: ProducerState

closed class-attribute instance-attribute #

closed = True

producer property #

producer: AIOKafkaProducer

stop async #

stop() -> None
Source code in faststream/kafka/publisher/state.py 
39
40
async def stop(self) -> None:
    pass

flush async #

flush() -> None
Source code in faststream/kafka/publisher/state.py 
42
43
async def flush(self) -> None:
    pass