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.