Skip to content

ChannelBinding

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

Bases: BaseModel

A class to represent a channel binding.

ATTRIBUTE DESCRIPTION
topic

optional string representing the topic
partitions

optional positive integer representing the number of partitions
replicas

optional positive integer representing the number of replicas
bindingVersion

string representing the binding version

topic class-attribute instance-attribute #

topic = None

partitions class-attribute instance-attribute #

partitions = None

replicas class-attribute instance-attribute #

replicas = None

bindingVersion class-attribute instance-attribute #

bindingVersion = '0.4.0'

from_sub classmethod #

from_sub(binding)
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)
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,
    )