Skip to content

FakeAioKafkaFastProducer

faststream.kafka.publisher.producer.FakeAioKafkaFastProducer #

Bases: AioKafkaFastProducer

closed property #

closed: bool

connect async #

connect(
    producer: AIOKafkaProducer,
    serializer: Optional[SerializerProto],
) -> None
Source code in faststream/kafka/publisher/producer.py 
169
170
171
172
173
174
async def connect(
    self,
    producer: "AIOKafkaProducer",
    serializer: Optional["SerializerProto"],
) -> None:
    raise NotImplementedError

disconnect async #

disconnect() -> None
Source code in faststream/kafka/publisher/producer.py 
176
177
async def disconnect(self) -> None:
    raise NotImplementedError

flush async #

flush() -> None
Source code in faststream/kafka/publisher/producer.py 
186
187
async def flush(self) -> None:
    raise NotImplementedError

publish async #

publish(
    cmd: KafkaPublishCommand,
) -> Union[Future[RecordMetadata], RecordMetadata]
Source code in faststream/kafka/publisher/producer.py 
189
190
191
192
193
async def publish(
    self,
    cmd: "KafkaPublishCommand",
) -> Union["asyncio.Future[RecordMetadata]", "RecordMetadata"]:
    raise NotImplementedError

publish_batch async #

publish_batch(
    cmd: KafkaPublishCommand,
) -> Union[Future[RecordMetadata], RecordMetadata]
Source code in faststream/kafka/publisher/producer.py 
195
196
197
198
199
async def publish_batch(
    self,
    cmd: "KafkaPublishCommand",
) -> Union["asyncio.Future[RecordMetadata]", "RecordMetadata"]:
    raise NotImplementedError

request async #

request(cmd: KafkaPublishCommand) -> Any
Source code in faststream/kafka/publisher/producer.py 
58
59
60
async def request(self, cmd: "KafkaPublishCommand") -> Any:
    msg = "Kafka doesn't support `request` method without test client."
    raise FeatureNotSupportedException(msg)