blob: 5c041134194c8b7ff8371d43fc7016639551e1f0 (
plain)
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();
}
}
|