PlaintextSettings

pydantic model safir.kafka.PlaintextSettings

Subset of settings required for Plaintext auth.

Parameters:

data (Any)

Fields:

• bootstrap_servers (str)

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

field bootstrap_servers: str [Required]

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

to_aiokafka_params()

Return type:

AIOKafkaParams

to_faststream_params()

Return type:

FastStreamBrokerParams