Skip to content

ConsumerProtocol

faststream.kafka.message.ConsumerProtocol #

Bases: Protocol

A protocol for Kafka consumers.

commit async #

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