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.