Skip to content

OperationBinding

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

Bases: BaseModel

A class to represent an operation binding.

ATTRIBUTE DESCRIPTION
groupId

optional dictionary representing the group ID
clientId

optional dictionary representing the client ID
replyTo

optional dictionary representing the reply-to
bindingVersion

version of the binding (default: "0.4.0")

groupId class-attribute instance-attribute #

groupId = None

clientId class-attribute instance-attribute #

clientId = None

replyTo class-attribute instance-attribute #

replyTo = 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/operation.py 
29
30
31
32
33
34
35
36
37
38
@classmethod
def from_sub(cls, binding: kafka.OperationBinding | None) -> Self | None:
    if not binding:
        return None

    return cls(
        groupId=binding.group_id,
        clientId=binding.client_id,
        replyTo=binding.reply_to,
    )

from_pub classmethod #

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

    return cls(
        groupId=binding.group_id,
        clientId=binding.client_id,
        replyTo=binding.reply_to,
    )