Skip to content

RealProducer

faststream.kafka.publisher.state.RealProducer #

RealProducer(producer: AIOKafkaProducer)

Bases: ProducerState

Source code in faststream/kafka/publisher/state.py 
49
50
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 
55
56
async def stop(self) -> None:
    await self.producer.stop()

flush async #

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