A scala-maven based project using kafka, spark and twitter.
A kakfa producer is sendind a stream of twitter messages ( using twitter4j library ) to kafka broker.
A spark consumer is consuming the messages from kafka and displaying a word count of the most used word over a period of 60 secs and printign those words with their count.
-
Notifications
You must be signed in to change notification settings - Fork 0
millwala53/kafka-twitter-scala-spark-project
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
A scala-maven based project using kafka, spark and twitter.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published