SslSettings

pydantic model safir.kafka.SslSettings

Subset of settings required for SSL auth.

Parameters:

data (Any)

Fields:

• bootstrap_servers (str)

• client_cert_path (pathlib.Path)

• client_key_path (pathlib.Path)

• cluster_ca_path (pathlib.Path)

• security_protocol (Literal[safir.kafka._kafka_config.SecurityProtocol.SSL])

field bootstrap_servers: str [Required]

field client_cert_path: Annotated[Path] [Required]

Constraints:

• path_type = file

field client_key_path: Annotated[Path] [Required]

Constraints:

• path_type = file

field cluster_ca_path: Annotated[Path] [Required]

Constraints:

• path_type = file

field security_protocol: Literal[<SecurityProtocol.SSL: 'SSL'>] [Required]

to_aiokafka_params()

Return type:

AIOKafkaParams

to_faststream_params()

Return type:

FastStreamBrokerParams

to_ssl_context()

Create an SSL context for connecting to Kafka.

Return type:

SSLContext