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);
	}
public static void main ( String [ ] args ) throws Exception { final KafkaCollector [ ] collectors = new KafkaCollector [ NUM_PARTITIONS ] ; for ( int i = 0 ; i < collectors . length ; i ++ ) { collectors [ i ] = new KafkaCollector ( BROKER_ADDRESS , TOPIC , i ) ; } StandaloneThreadedGenerator . runGenerator ( collectors ) ; }
Entry point to the kafka data producer.