Skip to content

KafkaSubscriberConfig

faststream.kafka.subscriber.config.KafkaSubscriberConfig dataclass #

KafkaSubscriberConfig(
    *,
    _outer_config: KafkaBrokerConfig = KafkaBrokerConfig(),
    no_reply: bool = False,
    _ack_policy: AckPolicy = (lambda: EMPTY)(),
    topics: Sequence[str] = list(),
    group_id: str | None = None,
    connection_args: dict[str, Any] = dict(),
    listener: Optional[ConsumerRebalanceListener] = None,
    pattern: str | None = None,
    partitions: Iterable[TopicPartition] = list(),
    _auto_commit: bool = (lambda: EMPTY)(),
    _no_ack: bool = (lambda: EMPTY)(),
)

Bases: SubscriberUsecaseConfig

topics class-attribute instance-attribute #

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

group_id class-attribute instance-attribute #

group_id: str | None = None

connection_args class-attribute instance-attribute #

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

listener class-attribute instance-attribute #

listener: Optional[ConsumerRebalanceListener] = None

pattern class-attribute instance-attribute #

pattern: str | None = None

partitions class-attribute instance-attribute #

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

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)