code: private ExecutorService _createExecutorService() {
          int producerConnections = Math.max(Integer.valueOf(
              _configuration.getValue(Property.KAFKA_PRODUCER_CONNECTIONS.getName(), Property.KAFKA_PRODUCER_CONNECTIONS.getDefaultValue())), 10);
  
          return Executors.newFixedThreadPool(producerConnections, new ThreadFactory() {
  
                  AtomicInteger id = new AtomicInteger(0);
  
                  @Override
                  public Thread newThread(Runnable r) {
                      return new Thread(r, MessageFormat.format("kafka-producer-worker-{0}", id.getAndIncrement()));
                  }
              });
      }
docs: ~ Methods **************************************************************************************************************************************