Function sql::plan::statement::ddl::kafka_sink_builder

fn kafka_sink_builder(
    format: Option<Format<Raw>>, 
    consistency: Option<KafkaConsistency<Raw>>, 
    with_options: &mut BTreeMap<String, Value>, 
    broker: String, 
    topic_prefix: String, 
    relation_key_indices: Option<Vec<usize>>, 
    key_desc_and_indices: Option<(RelationDesc, Vec<usize>)>, 
    value_desc: RelationDesc, 
    topic_suffix_nonce: String, 
    root_dependencies: &[&dyn CatalogItem]
) -> Result<SinkConnectorBuilder, Error>