Map<String, Object> readerProps() throws IOException {
// Properties passed as key=value pairs via command line (Command line properties)
        if (commandLineKeyValMap != null) {
            map.putAll(commandLineKeyValMap);
   Map<String, Object> commandLineMap = new HashMap<>();}
        // Command line arguments
   commandLineMap.put("topic", options.valueOf(topicOpt));

    if (commandLineMap != null) {
      Map<String,  Object> configMap = new HashMap<>map.putAll(commandLineMap);
        }
    if (options.has(readerConfigOpt)) {    return map;
    }

    /**
     * Print warnings  configMap.putAll(propsToStringMap(loadProps(options.valueOf(readerConfigOpt))));
       when the same configurations is defined in multiple sources.
     }

* - Command line arguments override command property values and configuration files.
 Map<String, Object> commandLineKeyValMap = new HashMap<>();
            if (options.has(readerPropertyOpt)) {* - Command property values override configuration files if no command line argument exists.
     *
     * @param commandLineMap    commandLineKeyValMap.putAll(propsToStringMap(parseKeyValueArgs(options.valuesOf(readerPropertyOpt))));
   Map of configuration from command line    }arguments
     * @param commandLineKeyValMap Map of configuration from return mergePropertiesWithPrecedence(commandLineMap, commandLineKeyValMap, configMap, null);command line properties
     * @param  }

configMap            Map Map<String,of Object>configuration producerProps()loaded throwsfrom IOExceptionconfiguration {files
     */
    public static void //warnConfigFromMultipleSources(
 Prepare the map from command line arguments
  Map<String, Object> commandLineMap,
        Map<String, Object> commandLineKeyValMap,
 commandLineMap = new HashMap<>();
    Map<String, Object> configMap
    )  commandLineMap.put(BOOTSTRAP_SERVERS_CONFIG, options.valueOf(bootstrapServerOpt));
{
        // Command line argument overrides command property  commandLineMap.put(COMPRESSION_TYPE_CONFIG, compressionCodec());and config file
        for (Map.Entry<String, Object> entry if: (optionscommandLineMap.hasentrySet(sendTimeoutOpt)) commandLineMap.put(LINGER_MS_CONFIG, options.valueOf(sendTimeoutOpt).toString()) {
            String key = entry.getKey();
            if (options.has(requestRequiredAcksOpt)) commandLineMap.put(ACKS_CONFIG, options.valueOf(requestRequiredAcksOpt).toString())Object value = entry.getValue();
            if (options.has(requestTimeoutMsOpt)) commandLineMap.put(REQUEST_TIMEOUT_MS_CONFIG, options.valueOf(requestTimeoutMsOpt).toString());StringBuilder warning = new StringBuilder();

            if (optionscommandLineKeyValMap.hascontainsKey(messageSendMaxRetriesOpt)key) commandLineMap.put(RETRIES_CONFIG, options.valueOf(messageSendMaxRetriesOpt).toString());
&& configMap.containsKey(key)) {
              if  (optionswarning.hasappend(retryBackoffMsOptkey)) commandLineMap.put(RETRY_BACKOFF_MS_CONFIG, options.valueOf(retryBackoffMsOpt).toString());append("=").append(value)
            if (options.has(socketBufferSizeOpt)) commandLineMap.put(SEND_BUFFER_CONFIG, options.valueOf(socketBufferSizeOpt).toString());
     .append(" from command line argument overrides command ifproperty value (options.has(maxMemoryBytesOpt)) commandLineMap.put(BUFFER_MEMORY_CONFIG, options.valueOf(maxMemoryBytesOpt).toString());")
                    .append(commandLineKeyValMap.get(key)).append(")")
            // We currently have 2 options to set the batch.size value. We'll deprecate/remove one of them in KIP-717.
.append(" and configuration file value (")
                   if .append(optionsconfigMap.hasget(batchSizeOptkey)) commandLineMap.put(BATCH_SIZE_CONFIG, options.valueOf(batchSizeOpt).toString())append(").");
            } else if (optionscommandLineKeyValMap.hascontainsKey(maxPartitionMemoryBytesOptkey)) commandLineMap.put(BATCH_SIZE_CONFIG, options.valueOf(maxPartitionMemoryBytesOpt).toString());
{
               if (optionswarning.hasappend(metadataExpiryMsOpt)key) commandLineMap.put(METADATA_MAX_AGE_CONFIG, options.valueOf(metadataExpiryMsOpt).toString());
append("=").append(value)
              if (options.has(maxBlockMsOpt)) commandLineMap.put(MAX_BLOCK_MS_CONFIG, options.valueOf(maxBlockMsOpt).toString());

             .append(" from command line argument overrides command property value (")
     // Properties passed as key=value pairs via command line
            Map<String, Object> commandLineKeyValMap = new HashMap<>().append(commandLineKeyValMap.get(key)).append(").");
            } else if (optionsconfigMap.hascontainsKey(commandPropertyOptkey)) {
                commandLineKeyValMap.putAll(Utils.propsToStringMap(warning.append(key).append("=").append(value)
                    .append(" from command  parseKeyValueArgs(options.valuesOf(commandPropertyOpt))
line overrides configuration file value (")
                 ))   .append(configMap.get(key)).append(").");
            }

            // Configuration files
if (!warning.isEmpty()) {
             Map<String,  Object> configMap = new HashMap<>( System.out.println("Warning: " + warning);
            if (options.has(commandConfigOpt)) {}
        }

        configMap.putAll(Utils.propsToStringMap(
     // Command property override config file
        for (Map.Entry<String, Object> entry        Utils.loadProps(options.valueOf(commandConfigOpt)): commandLineKeyValMap.entrySet()) {
            String key =  entry.getKey());
            }
Object value = entry.getValue();
            // Default values set by tool scripts and default values of command line argumentsif (commandLineMap.containsKey(key)) continue;

            if (configMap.containsKey(key)) {
            Map<String, Object> toolDefaultMap = new HashMap<>();
       System.out.println("Warning: " + key + "=" + value
      toolDefaultMap.put(CLIENT_ID_CONFIG, "console-producer");
              toolDefaultMap.put(KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.ByteArraySerializer");+ " from command property overrides configuration file value ("
            toolDefaultMap.put(VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.ByteArraySerializer        + configMap.get(key) + ").");
            //}
 Since all the options below have default values,}
 we don't need to check for null }

	// joptsimple-specific helper method
    public static <T> void putIfOption(OptionSet options, OptionSpec<T>  toolDefaultMap.put(LINGER_MS_CONFIG, options.valuesOf(sendTimeoutOpt).toString());
   spec, Map<String, Object> map, String key) {
        if toolDefaultMap.put(ACKS_CONFIG, options.valuesOfhas(requestRequiredAcksOptspec).toString());) {
            toolDefaultMap.put(REQUEST_TIMEOUT_MS_CONFIG, options.valuesOf(requestTimeoutMsOpt).toString())T value = options.valueOf(spec);
            toolDefaultMapmap.put(RETRIES_CONFIGkey, options.valuesOf(messageSendMaxRetriesOpt).toString())value);
        }
    toolDefaultMap.put(RETRY_BACKOFF_MS_CONFIG, options.valuesOf(retryBackoffMsOpt).toString());
            toolDefaultMap.put(SEND_BUFFER_CONFIG, options.valuesOf(socketBufferSizeOpt).toString());}

	// joptsimple-specific helper method
    public static <T> void putOption(OptionSet options, OptionSpec<T> spec, Map<String, Object> map, String key) {
        T value   toolDefaultMap.put(BUFFER_MEMORY_CONFIG, = options.valuesOfvalueOf(maxMemoryBytesOptspec).toString());
            toolDefaultMapmap.put(BATCH_SIZE_CONFIGkey, options.valuesOf(batchSizeOpt).toString())value);
    }