Skip to content

OperationBinding

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

Bases: BaseModel

A class to represent an operation binding.

groupId class-attribute instance-attribute #

groupId: dict[str, Any] | None = None

clientId class-attribute instance-attribute #

clientId: dict[str, Any] | None = None

replyTo class-attribute instance-attribute #

replyTo: dict[str, Any] | None = None

bindingVersion class-attribute instance-attribute #

bindingVersion: str = '0.4.0'

from_sub classmethod #

from_sub(binding: OperationBinding | None) -> Self | None
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: OperationBinding | None) -> Self | None
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,
    )