public static String createClientId(String prefix, Config config) {

    Pair<String, String> jobNameId = getJobNameAndId(config);
    String jobName = jobNameId.getLeft();
    String jobId = jobNameId.getRight();
    return String.format("%s-%s-%s", prefix.replaceAll("\\W", "_"), jobName.replaceAll("\\W", "_"),
        jobId.replaceAll("\\W", "_"));
  }
Create kafka consumer configs, based on the subset of global configs.
@param config application config
@param systemName system name
@param clientId client id provided by the caller
@return KafkaConsumerConfig
samza-kafka/src/main/java/org/apache/samza/config/KafkaConsumerConfig.java