Skip to content

KafkaPublisherConfig

faststream.kafka.publisher.config.KafkaPublisherConfig `dataclass` #

KafkaPublisherConfig(
    *,
    _outer_config: KafkaBrokerConfig = KafkaBrokerConfig(),
    key: bytes | str | None,
    topic: str,
    partition: int | None,
    headers: Mapping[str, str | bytes | None] | None,
    reply_to: str,
)

Bases: PublisherUsecaseConfig

key `instance-attribute` #

key: bytes | str | None

topic `instance-attribute` #

topic: str

partition `instance-attribute` #

partition: int | None

headers `instance-attribute` #

headers: Mapping[str, str | bytes | None] | None

reply_to `instance-attribute` #

reply_to: str