private String getQueryId() {
    return HiveConf.getVar(getConf(), HiveConf.ConfVars.HIVE_QUERY_ID);
  }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java