1 import java.io.IOException;
3 public class kafka2hdfsApp {
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]);
10 CreateKafkaConsumer createKafkaConsumer = new CreateKafkaConsumer();
11 createKafkaConsumer.processKafkaMessage();