static Config mergeConfig(Map<String, String> originalConfig, Map<String, String> generatedConfig) {
    validateJobConfigs(originalConfig, generatedConfig);
    Map<String, String> mergedConfig = new HashMap<>(generatedConfig);

    originalConfig.forEach((k, v) -> {
      if (generatedConfig.containsKey(k) && !Objects.equals(generatedConfig.get(k), v)) {
        LOG.info("Replacing generated config for key: {} value: {} with original config value: {}", k, generatedConfig.get(k), v);
      }
      mergedConfig.put(k, v);
    });

    return ConfigUtil.rewriteConfig(new MapConfig(mergedConfig));
  }
This class provides methods to generate configuration for a {@link JobNode}
samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java