mz_sql::plan::statement::ddl::connection

Function plan_kafka_security

Source 
fn plan_kafka_security(
    scx: &StatementContext<'_>,
    v: &ConnectionOptionExtracted,
) -> Result<(Option<KafkaTlsConfig>, Option<KafkaSaslConfig<ReferencedConnection>>), PlanError>