jmetalsp-streamingdatasource/src/main/java/org/uma/jmetalsp/examples/streamingdatasource/SimpleStreamingCounterDataSourceAVRO.java
public static void main(String[] args) {
		String topicName = "prueba-int-topic-from-main" ;

		SimpleStreamingCounterDataSourceAVRO simpleStreamingCounterDataSource =
				new SimpleStreamingCounterDataSourceAVRO(
						new KafkaObservable<>(topicName, "avsc/Counter.avsc"), 2000) ;

		simpleStreamingCounterDataSource.run();
	}
/**
	 * main() method to run the streaming por
	 * @param args
	 */
main() method to run the streaming por
@param args
main () method to run the streaming por @param args
public static void main(String[] args) {
		String topicName = "prueba-int-topic-from-main" ;
		SimpleStreamingCounterDataSourceAVRO simpleStreamingCounterDataSource =
				new SimpleStreamingCounterDataSourceAVRO(
						new KafkaObservable<>(topicName, "avsc/Counter.avsc"), 2000) ;
		simpleStreamingCounterDataSource.run();
	}
public static void main ( String [ ] args ) { String topicName = "prueba-int-topic-from-main" ; SimpleStreamingCounterDataSourceAVRO simpleStreamingCounterDataSource = new SimpleStreamingCounterDataSourceAVRO ( new KafkaObservable < > ( topicName , "avsc/Counter.avsc" ) , 2000 ) ; simpleStreamingCounterDataSource . run ( ) ; }
main() method to run the streaming por
 @param args
main () method to run the streaming por @param args