Skip to content

FakeConsumer

faststream.kafka.message.FakeConsumer #

A fake Kafka consumer.

commit async #

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