public static ClassLoader getContextOrKafkaClassLoader() {
        ClassLoader cl = Thread.currentThread().getContextClassLoader();
        if (cl == null)
            return getKafkaClassLoader();
        else
            return cl;
    }
Get the Context ClassLoader on this thread or, if not present, the ClassLoader that
loaded Kafka.

This should be used whenever passing a ClassLoader to Class.forName
clients/src/main/java/org/apache/kafka/common/utils/Utils.java