vnfs/DAaaS/training-core/hdfs-writer-source-code/hdfs-writer/src/main/java/kafka2hdfsApp.java

   1 import java.io.IOException;
   2
   3 public class kafka2hdfsApp {
   4
   5     public static void main(String[] args) throws IOException {
   6         System.out.println("Begin::: kafka2hdfsApp");
   7         Orchestrator orchestrator = new Orchestrator();
   8         orchestrator.init(args[1]);
   9
  10         CreateKafkaConsumer createKafkaConsumer = new CreateKafkaConsumer();
  11         createKafkaConsumer.processKafkaMessage();
  12
  13     }
  14 }