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._local.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: FilePath | None [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, SecurityProtocol.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