Skip to content

TopicPartition

faststream.confluent.TopicPartition #

TopicPartition(
    topic: str,
    partition: int = -1,
    offset: int = -1001,
    metadata: str | None = None,
    leader_epoch: int | None = None,
)
Source code in faststream/confluent/schemas/partition.py 
25
26
27
28
29
30
31
32
33
34
35
36
37
def __init__(
    self,
    topic: str,
    partition: int = -1,
    offset: int = -1001,
    metadata: str | None = None,
    leader_epoch: int | None = None,
) -> None:
    self.topic = topic
    self.partition = partition
    self.offset = offset
    self.metadata = metadata
    self.leader_epoch = leader_epoch

topic instance-attribute #

topic = topic

partition instance-attribute #

partition = partition

offset instance-attribute #

offset = offset

metadata instance-attribute #

metadata = metadata

leader_epoch instance-attribute #

leader_epoch = leader_epoch

to_confluent #

to_confluent() -> TopicPartition
Source code in faststream/confluent/schemas/partition.py 
39
40
41
42
43
44
45
46
47
48
49
def to_confluent(self) -> ConfluentPartition:
    kwargs: _TopicKwargs = {
        "topic": self.topic,
        "partition": self.partition,
        "offset": self.offset,
    }
    if self.metadata is not None:
        kwargs["metadata"] = self.metadata
    if self.leader_epoch is not None:
        kwargs["leader_epoch"] = self.leader_epoch
    return ConfluentPartition(**kwargs)

add_prefix #

add_prefix(prefix: str) -> TopicPartition
Source code in faststream/confluent/schemas/partition.py 
51
52
53
54
55
56
57
58
def add_prefix(self, prefix: str) -> "TopicPartition":
    return TopicPartition(
        topic=f"{prefix}{self.topic}",
        partition=self.partition,
        offset=self.offset,
        metadata=self.metadata,
        leader_epoch=self.leader_epoch,
    )