Skip to content

KafkaPublisherConfig

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

KafkaPublisherConfig(
    *,
    _outer_config: KafkaBrokerConfig = KafkaBrokerConfig(),
    middlewares: Sequence[PublisherMiddleware[Any]],
    key: bytes | str | None,
    topic: str,
    partition: int | None,
    headers: dict[str, str] | 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: dict[str, str] | None

reply_to `instance-attribute` #

reply_to: str

middlewares `instance-attribute` #

middlewares: Sequence[PublisherMiddleware[Any]]