Skip to content

FakeConsumer

faststream.confluent.message.FakeConsumer #

A fake Kafka consumer.

commit async #

commit()
Source code in faststream/confluent/message.py 
24
25
async def commit(self) -> None:
    pass

seek async #

seek(topic, partition, offset)
Source code in faststream/confluent/message.py 
27
28
29
30
31
32
33
async def seek(
    self,
    topic: str | None,
    partition: int | None,
    offset: int | None,
) -> None:
    pass