@Override public void configureInputJobProperties(TableDesc tableDesc, Map<String, String> jobProperties) {
    configureCommonProperties(tableDesc, jobProperties);
  }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java