protected KafkaProducer<K, V> createProducer(Properties props) {
    return this.closer.register(new KafkaProducer<K, V>(props));
  }
protected KafkaProducer < K , V > createProducer ( Properties props ) { return this . closer . register ( new KafkaProducer < K , V > ( props ) ) ; }
Create the Kafka producer.