X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=vnfs%2FDAaaS%2Ftraining-core%2Fhdfs-writer-source-code%2Fhdfs-writer%2Fsrc%2Fmain%2Fjava%2Fkafka2hdfsApp.java;fp=vnfs%2FDAaaS%2Ftraining-core%2Fhdfs-writer-source-code%2Fhdfs-writer%2Fsrc%2Fmain%2Fjava%2Fkafka2hdfsApp.java;h=5c041134194c8b7ff8371d43fc7016639551e1f0;hb=b6555bc1f55e82a4436232ec28b2f5e50600d70d;hp=0000000000000000000000000000000000000000;hpb=2e3e9ce49761fa60e9605a5c4ac74c1509596029;p=demo.git

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
index 00000000..5c041134
--- /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();
+
+    }
+}