Skip to content

FakeConsumer

faststream.confluent.message.FakeConsumer #

A fake Kafka consumer.

commit async #

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

seek async #

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