Skip to content

FakeConsumer

faststream.kafka.message.FakeConsumer #

A fake Kafka consumer.

commit async #

commit()
Source code in faststream/kafka/message.py 
27
28
async def commit(self) -> None:
    pass

seek #

seek(partition, offset)
Source code in faststream/kafka/message.py 
30
31
32
33
34
35
def seek(
    self,
    partition: AIOKafkaTopicPartition,
    offset: int,
) -> None:
    pass