Created a spark submit job that processed tweet, as well as returned processed tweet to kafka topic:"test5"
rloustaunau13 / kafkatospark Goto Github PK
View Code? Open in Web Editor NEWcreates dstream and filters tweets using stanfotd nlp, sends back to kafka topic:test5