Skip to content

RealProducer

faststream.kafka.publisher.state.RealProducer #

RealProducer(producer: AIOKafkaProducer)

Bases: ProducerState

Source code in faststream/kafka/publisher/state.py 
47
48
def __init__(self, producer: "AIOKafkaProducer") -> None:
    self.producer = producer

producer instance-attribute #

producer = producer

closed property #

closed: bool

stop async #

stop() -> None
Source code in faststream/kafka/publisher/state.py 
53
54
async def stop(self) -> None:
    await self.producer.stop()

flush async #

flush() -> None
Source code in faststream/kafka/publisher/state.py 
60
61
async def flush(self) -> None:
    await self.producer.flush()