Skip to content

KafkaSubscriberConfig

faststream.confluent.subscriber.config.KafkaSubscriberConfig dataclass #

KafkaSubscriberConfig(
    *,
    _outer_config: KafkaBrokerConfig = KafkaBrokerConfig(),
    no_reply: bool = False,
    _ack_policy: AckPolicy = (lambda: EMPTY)(),
    topics: Sequence[str] = list(),
    partitions: Sequence[TopicPartition] = list(),
    polling_interval: float = 0.1,
    group_id: str | None = None,
    connection_data: dict[str, Any] = dict(),
    _auto_commit: bool = (lambda: EMPTY)(),
    _no_ack: bool = (lambda: EMPTY)(),
)

Bases: SubscriberUsecaseConfig

topics class-attribute instance-attribute #

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

partitions class-attribute instance-attribute #

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

polling_interval class-attribute instance-attribute #

polling_interval: float = 0.1

group_id class-attribute instance-attribute #

group_id: str | None = None

connection_data class-attribute instance-attribute #

connection_data: dict[str, Any] = field(
    default_factory=dict
)

ack_first property #

ack_first: bool

auto_ack_disabled property #

auto_ack_disabled: bool

ack_policy property #

ack_policy: AckPolicy

no_reply class-attribute instance-attribute #

no_reply: bool = False

parser class-attribute instance-attribute #

parser: AsyncCallable = field(init=False)

decoder class-attribute instance-attribute #

decoder: AsyncCallable = field(init=False)