Function mz_sql::plan::statement::ddl::kafka_sink_builder

fn kafka_sink_builder(
    scx: &StatementContext<'_>,
    connection: ResolvedItemName,
    options: Vec<KafkaSinkConfigOption<Aug>>,
    format: Option<Format<Aug>>,
    relation_key_indices: Option<Vec<usize>>,
    key_desc_and_indices: Option<(RelationDesc, Vec<usize>)>,
    value_desc: RelationDesc,
    envelope: SinkEnvelope,
    sink_from: GlobalId
) -> Result<StorageSinkConnection<ReferencedConnection>, PlanError>