SslSettings#

pydantic model safir.kafka.SslSettings#

Subset of settings required for SSL auth.

Parameters:

data (Any)

Fields:
field bootstrap_servers: str [Required]#
field client_cert_path: FilePath [Required]#
Constraints:
  • path_type = file

field client_key_path: FilePath [Required]#
Constraints:
  • path_type = file

field cluster_ca_path: FilePath [Required]#
Constraints:
  • path_type = file

field security_protocol: Literal[SecurityProtocol.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