Function mz_dataflow_types::populate_client_config
source · [−]pub fn populate_client_config(
kafka_connection: KafkaConnection,
options: &BTreeMap<String, StringOrSecret>,
drop_option_keys: HashSet<&'static str>,
config: &mut ClientConfig,
secrets_reader: &SecretsReader
)
Expand description
Propagates appropriate configuration options from kafka_connection
and
options
into config
, ignoring any options identified in
drop_option_keys
.
Note that this:
- Performs blocking reads when extracting SECRETS.
- Does not ensure that the keys from the Kafka connection and additional options are disjoint.