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


1
2
3
4
5
6
7
8
9
10
11
12
13
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();

    }
}