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.