Merge "Source code initial workingDraft kafka2hdfs writer."

[demo.git] / vnfs / DAaaS / training-core / hdfs-writer-source-code / hdfs-writer / src / main / java / kafka2hdfsApp.java

diff --git a/vnfs/DAaaS/training-core/hdfs-writer-source-code/hdfs-writer/src/main/java/kafka2hdfsApp.java b/vnfs/DAaaS/training-core/hdfs-writer-source-code/hdfs-writer/src/main/java/kafka2hdfsApp.java
new file mode 100644 (file)
index 0000000..5c04113
--- /dev/null
+++ b/vnfs/DAaaS/training-core/hdfs-writer-source-code/hdfs-writer/src/main/java/kafka2hdfsApp.java
@@ -0,0 +1,14 @@
+import java.io.IOException;
+
+public class kafka2hdfsApp {
+
+    public static void main(String[] args) throws IOException {
+        System.out.println("Begin::: kafka2hdfsApp");
+        Orchestrator orchestrator = new Orchestrator();
+        orchestrator.init(args[1]);
+
+        CreateKafkaConsumer createKafkaConsumer = new CreateKafkaConsumer();
+        createKafkaConsumer.processKafkaMessage();
+
+    }
+}