Function dataflow::source::kafka::create_kafka_config[][src]

fn create_kafka_config(
    name: &str,
    addrs: &KafkaAddrs,
    group_id_prefix: Option<String>,
    cluster_id: Uuid,
    config_options: &BTreeMap<String, String>
) -> ClientConfig
Expand description

Creates a Kafka config.