Skip to content

ConsumerProtocol

faststream.confluent.message.ConsumerProtocol #

Bases: Protocol

A protocol for Kafka consumers.

commit async #

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

seek async #

seek(topic: str, partition: int, offset: int) -> None
Source code in faststream/confluent/message.py 
13
14
15
16
17
18
async def seek(
    self,
    topic: str,
    partition: int,
    offset: int,
) -> None: ...