@Override public void configureJobConf(TableDesc tableDesc, JobConf jobConf) {
    Map<String, String> properties = new HashMap<>();
    configureInputJobProperties(tableDesc, properties);
    configureOutputJobProperties(tableDesc, properties);
    properties.forEach(jobConf::set);
    try {
      KafkaUtils.copyDependencyJars(jobConf, KafkaStorageHandler.class);
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
  }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java