Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class Main {
- public void operate(){
- JavaInputDStream<B> messages = KafkaUtils.createDirectStream(
- jssc,
- LocationStrategies.PreferConsistent(),
- ConsumerStrategies.<A, B>Subscribe(topicsSet, kafkaParams));
- OneClass oc = new OneClass();
- messages.forEachRDD(record -> {
- TwoClass tc= new TwoClass();
- tc.compute();
- oc.add();
- });
- } //operate ends here
- } //Main class ends here
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement