Skip to content

ChannelBinding

faststream.specification.asyncapi.v2_6_0.schema.bindings.kafka.ChannelBinding #

Bases: BaseModel

A class to represent a channel binding.

topic class-attribute instance-attribute #

topic: str | None = None

partitions class-attribute instance-attribute #

partitions: PositiveInt | None = None

replicas class-attribute instance-attribute #

replicas: PositiveInt | None = None

bindingVersion class-attribute instance-attribute #

bindingVersion: str = '0.4.0'

from_sub classmethod #

from_sub(binding: ChannelBinding | None) -> Self | None
Source code in faststream/specification/asyncapi/v2_6_0/schema/bindings/kafka/channel.py 
30
31
32
33
34
35
36
37
38
39
@classmethod
def from_sub(cls, binding: kafka.ChannelBinding | None) -> Self | None:
    if binding is None:
        return None

    return cls(
        topic=binding.topic,
        partitions=binding.partitions,
        replicas=binding.replicas,
    )

from_pub classmethod #

from_pub(binding: ChannelBinding | None) -> Self | None
Source code in faststream/specification/asyncapi/v2_6_0/schema/bindings/kafka/channel.py 
41
42
43
44
45
46
47
48
49
50
@classmethod
def from_pub(cls, binding: kafka.ChannelBinding | None) -> Self | None:
    if binding is None:
        return None

    return cls(
        topic=binding.topic,
        partitions=binding.partitions,
        replicas=binding.replicas,
    )