@Override public void cleanup() {
        producersMap.forEach((s, producer) -> producer.close(Duration.ofMillis(0)));
        producersMap.clear();
      }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java