Skip to content

KafkaSubscriberConfig

faststream.kafka.subscriber.config.KafkaSubscriberConfig dataclass #

KafkaSubscriberConfig(
    *,
    _outer_config=KafkaBrokerConfig(),
    no_reply=False,
    _ack_policy=(lambda: EMPTY)(),
    topics=list(),
    group_id=None,
    connection_args=dict(),
    listener=None,
    pattern=None,
    partitions=list(),
    _auto_commit=(lambda: EMPTY)(),
    _no_ack=(lambda: EMPTY)(),
)

Bases: SubscriberUsecaseConfig

topics class-attribute instance-attribute #

topics = field(default_factory=list)

group_id class-attribute instance-attribute #

group_id = None

connection_args class-attribute instance-attribute #

connection_args = field(default_factory=dict)

listener class-attribute instance-attribute #

listener = None

pattern class-attribute instance-attribute #

pattern = None

partitions class-attribute instance-attribute #

partitions = field(default_factory=list)

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)