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 
15
async def commit(self) -> None: ...

seek #

seek(partition: TopicPartition, offset: int) -> None
Source code in faststream/kafka/message.py 
17
18
19
20
21
22
def seek(
    self,
    partition: AIOKafkaTopicPartition,
    offset: int,
) -> None:
    pass