Skip to content

ConsumerProtocol

faststream.confluent.message.ConsumerProtocol #

Bases: Protocol

A protocol for Kafka consumers.

commit async #

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

seek async #

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