code: public static void main(String[] args) throws Exception {
  
  		final KafkaCollector[] collectors = new KafkaCollector[NUM_PARTITIONS];
  
  		// create the generator threads
  		for (int i = 0; i < collectors.length; i++) {
  			collectors[i] = new KafkaCollector(BROKER_ADDRESS, TOPIC, i);
  		}
  
  		StandaloneThreadedGenerator.runGenerator(collectors);
  	}
docs: Entry point to the kafka data producer.