EmptyProducerState

faststream.kafka.publisher.state.EmptyProducerState

Bases: ProducerState

closed class-attribute instance-attribute

closed = True

producer property

producer

stop async

stop()

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

async def stop(self) -> None:
    pass

flush async

flush()

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

async def flush(self) -> None:
    pass