SaslSslSettings

pydantic model safir.kafka.SaslSslSettings

Subset of settings required for SASL PLAINTEXT auth.

Parameters:

data (Any)

Fields:

• bootstrap_servers (str)

• cluster_ca_path (pathlib.Path | None)

• sasl_mechanism (safir.kafka._kafka_config.SaslMechanism)

• sasl_password (pydantic.types.SecretStr)

• sasl_username (str)

• security_protocol (Literal[safir.kafka._kafka_config.SecurityProtocol.SASL_PLAINTEXT, safir.kafka._kafka_config.SecurityProtocol.SASL_SSL])

field bootstrap_servers: str [Required]

field cluster_ca_path: Optional[Annotated[Path]] [Required]

field sasl_mechanism: SaslMechanism = SaslMechanism.SCRAM_SHA_512

field sasl_password: SecretStr [Required]

field sasl_username: str [Required]

field security_protocol: Literal[<SecurityProtocol.SASL_PLAINTEXT: 'SASL_PLAINTEXT'>, <SecurityProtocol.SASL_SSL: 'SASL_SSL'>] [Required]

to_aiokafka_params()

Return type:

AIOKafkaParams

to_faststream_params()

Return type:

FastStreamBrokerParams

to_ssl_context()

Make an SSL context for connecting to Kafka.

Return type:

SSLContext