Skip to content

ConsumerProtocol

faststream.kafka.message.ConsumerProtocol #

Bases: Protocol

A protocol for Kafka consumers.

commit async #

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

seek #

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