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 ) ; }
Entry point to the kafka data producer .