Skip to content

KafkaSubscriberSpecificationConfig

faststream.kafka.subscriber.config.KafkaSubscriberSpecificationConfig `dataclass` #

KafkaSubscriberSpecificationConfig(
    *,
    title_: str | None,
    description_: str | None,
    include_in_schema: bool = True,
    topics: Sequence[str] = list(),
    partitions: Iterable[TopicPartition] = list(),
)

Bases: SubscriberSpecificationConfig

topics `class-attribute` `instance-attribute` #

topics: Sequence[str] = field(default_factory=list)

partitions `class-attribute` `instance-attribute` #

partitions: Iterable[TopicPartition] = field(
    default_factory=list
)

title_ `instance-attribute` #

title_: str | None

description_ `instance-attribute` #

description_: str | None

include_in_schema `class-attribute` `instance-attribute` #

include_in_schema: bool = True