Skip to content

KafkaSubscriberConfig

faststream.confluent.subscriber.config.KafkaSubscriberConfig dataclass #

KafkaSubscriberConfig(
    *,
    _outer_config=KafkaBrokerConfig(),
    no_reply=False,
    _ack_policy=(lambda: EMPTY)(),
    topics=list(),
    partitions=list(),
    polling_interval=0.1,
    group_id=None,
    connection_data=dict(),
    _auto_commit=(lambda: EMPTY)(),
    _no_ack=(lambda: EMPTY)(),
)

Bases: SubscriberUsecaseConfig

topics class-attribute instance-attribute #

topics = field(default_factory=list)

partitions class-attribute instance-attribute #

partitions = field(default_factory=list)

polling_interval class-attribute instance-attribute #

polling_interval = 0.1

group_id class-attribute instance-attribute #

group_id = None

connection_data class-attribute instance-attribute #

connection_data = field(default_factory=dict)

ack_first property #

ack_first

ack_policy property #

ack_policy

no_reply class-attribute instance-attribute #

no_reply = False

parser class-attribute instance-attribute #

parser = field(init=False)

decoder class-attribute instance-attribute #

decoder = field(init=False)