docs: private KafkaInternalConsumerRunner createConsumerRunner(Properties properties) throws Exception {
  
          ClassLoader previous = Thread.currentThread().getContextClassLoader();
          Thread.currentThread().setContextClassLoader(getClass().getClassLoader());
  
          try {
              Consumer<ByteBuffer, ByteBuffer> consumer = new KafkaConsumer<>(properties);
              return new KafkaInternalConsumerRunner(this, m_config, consumer);
          } finally {
              Thread.currentThread().setContextClassLoader(previous);
          }
      }