FakeAioKafkaFastProducer

faststream.kafka.publisher.producer.FakeAioKafkaFastProducer

Bases: AioKafkaFastProducer

closed property

closed

connect async

connect(producer, serializer)

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

async def connect(
    self,
    producer: "AIOKafkaProducer",
    serializer: Optional["SerializerProto"],
) -> None:
    raise NotImplementedError

disconnect async

disconnect()

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

async def disconnect(self) -> None:
    raise NotImplementedError

flush async

flush()

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

async def flush(self) -> None:
    raise NotImplementedError

publish async

publish(cmd)

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

async def publish(
    self,
    cmd: "KafkaPublishCommand",
) -> Union["asyncio.Future[RecordMetadata]", "RecordMetadata"]:
    raise NotImplementedError

publish_batch async

publish_batch(cmd)

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

async def publish_batch(
    self,
    cmd: "KafkaPublishCommand",
) -> Union["asyncio.Future[RecordMetadata]", "RecordMetadata"]:
    raise NotImplementedError

request async

request(cmd)

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

async def request(self, cmd: "KafkaPublishCommand") -> Any:
    msg = "Kafka doesn't support `request` method without test client."
    raise FeatureNotSupportedException(msg)