Function mz_storage::types::connections::populate_client_config
source · [−]pub async fn populate_client_config<'a>(
kafka_connection: KafkaConnection,
options: &'a BTreeMap<String, StringOrSecret>,
drop_option_keys: HashSet<&'static str>,
config: &'a mut ClientConfig,
secrets_reader: &'a dyn 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.